登录 注册
当前位置:主页 > 资源下载 > 12 > KafkaDashboard是一款仪表板实例,它运用了Kafka和Spark Streaming技术来整合日志并实时更新结果

KafkaDashboard是一款仪表板实例,它运用了Kafka和Spark Streaming技术来整合日志并实时更新结果

  • 更新:2024-07-04 09:52:44
  • 大小:622KB
  • 推荐:★★★★★
  • 来源:网友上传分享
  • 类别:其它 - 开发技术
  • 格式:ZIP

资源介绍

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