flink1.13 upsert-kafka connector 实时报表 视频演示

-- 下面两个建表语句是把kafka topic数据映射到flink1.13-sql中的虚拟表
-- 然后对其做个简单的join看一下效果
-- 这是实时报表或者实时数仓的一个起步demo. 

# kafka topic删除 // 如果你重新执行的话...
kafka-topics.sh --delete --zookeeper localhost:2181 --topic my

kafka-topics.sh --delete --zookeeper localhost:2181 --topic father

kafka-topics.sh --delete --zookeeper localhost:2181 --topic hasfather

kafka-topics.sh --delete --zookeeper localhost:2181 --topic nofather


# 新建这几个topic
/opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.9.99:9092 --topic my
/opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.9.99:9092 --topic father



# /opt/flink/bin/sql-client.sh embedded
# 建立kafka source的映射
drop table if exists me;
CREATE TABLE me (
  name string,
  age int
) WITH (
  'connector' = 'kafka',
  'topic' = 'my',
  'properties.bootstrap.servers' = '192.168.9.99:9092',
  'properties.group.id' = 'test',
  'format' &