文件名称：streaming-online-analytics-demo:使用Kafka的Dockerized Spark流
文件大小：143KB
文件格式：ZIP
更新时间：2024-06-15 14:40:14
docker webservice kafka analytics camel
Spark Online Analytics商店演示 该应用程序演示了如何使用Spark结构化流处理来自kafka主题的订单。 可以将订单存储在HDFS中，然后在实时流式传输数据时通过Spark SQL临时查询。 先决条件 环境： 卡夫卡 动物园管理员 码头工人 OpenShift v3或更高版本 卡桑德拉 建立和运行 make build 网址： Camel Order WebService：` 卡夫卡（Kafka）URL： http://localhost:9092 SparkMaster： http://localhost:8081 SparkWorker1： http://localhost:8082 Minio S3 Storage Alternative： http://localhost:9000/minio/docker/注：检查s3storage日志中的acc