-
KafkaDashboard是一款仪表板实例,它运用了Kafka和Spark Streaming技术来整合日志并实时更新结果
资源介绍
Kafka仪表板
这是一个使用Kafka和Spark Streaming来汇总日志并更新结果的仪表板示例。
先决条件:
火花:2.2.1
卡夫卡:1.1.0
Kafka-python:1.4.2
烧瓶:0.12.2
Flask-SocketIO:2.9.6
高图:6.1.0
用法:
克隆git仓库, git clone https://github.com/fudan-cyma/KafkaDashboard.git
cd KafkaDashboard
运行生产者, python ./scripts/producer.py
运行流客户端, /usr/local/spark/bin/spark-submit --jars /usr/local/spark/jars/spark-streaming-kafka-0-8-assembly_2.11-2.2.1.jar ./scri