文件名称：Kafka_Spark_Integration
文件大小：9KB
文件格式：ZIP
更新时间：2024-05-28 06:19:16
kafka spark spark-streaming Java
Kafka_Spark_Integration 该存储库是一个有关如何使用Apache Kafka和Apache Spark流设置生产者和消费者的maven项目。 套餐详情 Producer.Java从spark.txt中逐行读取内容，然后将消息发布到您的代理上。 Consumer.Java仅使用apache kafka构建。 sparkStreamingConsumer.Java使用Apache Spark的流功能构建。
【文件预览】：
Kafka_Spark_Integration-master
----.gitignore(278B)
----README.md(405B)
----pom.xml(2KB)
----spark_kafka_integration()
--------sparkStreamingConsumer.Java(2KB)
--------sparkConnection.java(1KB)
--------Producer.Java(2KB)
--------Consumer.Java(1KB)
----LICENSE(11KB)
----spark.txt(715B)