flink1.13 kafka connector 映射一张kafka表 demo

/opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.9.99:9092 --topic topicName1

sql-client.sh embedded

drop table if exists tb1;
CREATE TABLE tb1 (
  name1 int
) WITH (
  'connector' = 'kafka',
  'topic' = 'topicName1',
  'properties.bootstrap.servers' = '192.168.9.99:9092',
  'properties.group.id' = 'test',
  'format' = 'csv',
  'scan.startup.mode' = 'earliest-offset' 
);

select * from tb1;