视频对应的脚本

-- 下面两个建表语句是把kafka topic数据映射到flink1.13-sql中的虚拟表
-- 然后对其做个简单的join看一下效果
-- 这是实时报表或者实时数仓的一个起步demo. # kafka topic删除 // 如果你重新执行的话...
kafka-topics.sh --delete --zookeeper localhost:2181 --topic mykafka-topics.sh --delete --zookeeper localhost:2181 --topic fatherkafka-topics.sh --delete --zookeeper localhost:2181 --topic hasfatherkafka-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' &