1、启动日志生成程序(延时1秒发送一条日志)
2、登录hadoop102:9095查看
3、点击Load data->点击Apache Kafka
4、添加Kafka Broker和要消费的topic
5、确认数据样本格式
6、加载数据,必须要有时间字段
7、配置要加载哪些列
8、创建数据库表名
9、重新观察一下配置
10、连接Kafka的topic_start
11、点击SQL
12、查询指标select sum(mid) from "topic_start"
时间:2024-10-11 23:11:23
1、启动日志生成程序(延时1秒发送一条日志)
2、登录hadoop102:9095查看
3、点击Load data->点击Apache Kafka
4、添加Kafka Broker和要消费的topic
5、确认数据样本格式
6、加载数据,必须要有时间字段
7、配置要加载哪些列
8、创建数据库表名
9、重新观察一下配置
10、连接Kafka的topic_start
11、点击SQL
12、查询指标select sum(mid) from "topic_start"