项目目标
实时路况展现、未来路况预测
数据源
城市中每时每刻生成的海量数据
项目架构图
实时交通拥堵效果图
其他功能
程序架构图
卡口数据字段说明
二、 组件调试
2.1、kafka安装部署
2.2、测试kafka
创建topic
./bin/kafka-topics.sh -zookeeper idc007128:2181,idc007124:2181,idc007123:2181 -topic test -replication-factor 1 -partitions 1 -create
查看topic
./bin/kafka-topics.sh -zookeeper idc007128:2181,idc007124:2181,idc007123:2181
创建kafka 生产者
./bin/kafka-console-producer.sh --broker-list idc007130:9092 --topic test
创建kafka 消费者
./bin/kafka-console-consumer.sh --zookeeper idc007128:2181,idc007124:2181,idc007123:2181 --from-beginning -topic test