大数据全系列 教程
1869个小节阅读:466k
目录
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
违法车辆信息测试数据:
xxxxxxxxxx
京E32638,涉嫌套牌,1893427261000
京E32636,涉嫌套牌,1893427266000
京P32634,涉嫌套牌,1893427276000
京P32633,涉嫌套牌,1893427280000
京P32632,涉嫌套牌,1893427285000
京P32631,涉嫌套牌,1893427296000
出警记录测试数据:
xxxxxxxxxx
J0001,京E32638,处理完成,1893427265000
J0002,京NJA68X,处理完成,1893427271000
J0003,京E32636,处理完成,1893427277000
J0004,京NJA688,处理完成,1893427281000
J0005,京NJA681,处理完成,1893427283000
J0006,京NJA680,处理完成,1893427290000
扩展:违章信息来至于traffic-topicA,出警信息来至于traffic-topicB
创建主题:
xxxxxxxxxx
kafka-topics.sh --bootstrap-server node3:9092 --replication-factor 2 --partitions 3 --create --topic traffic-topicA
kafka-topics.sh --bootstrap-server node3:9092 --replication-factor 2 --partitions 3 --create --topic traffic-topicB
删除主题:
xxxxxxxxxx
kafka-topics.sh --bootstrap-server node3:9092 --delete --topic traffic-topicA
kafka-topics.sh --bootstrap-server node3:9092 --delete --topic traffic-topicB
生产数据:
xxxxxxxxxx
kafka-console-producer.sh --bootstrap-server node3:9092 --topic traffic-topicA
xxxxxxxxxx
kafka-console-producer.sh --bootstrap-server node3:9092 --topic traffic-topicB
代码参考:ViolationCarAndPoliceActionAnalysis3