文件名称:kafka-spark-integration:Kafka和Spark集成。 Maven项目中的Alll代码
文件大小:22KB
文件格式:ZIP
更新时间:2024-06-15 13:30:58
Java
kafka-spark-integration Kafka和Spark集成。 Maven项目中的Alll代码。 此存储库具有Java代码,用于指示如何向Kafka主题发送消息(生产者)如何从kafka主题接收消息(订阅者)如何从Kafka发送消息到Spark Stream。 Spark Steam如何从Kafka主题获取数据 消息-> Kafka-> Spark Stream-RDD
【文件预览】:
kafka-spark-integration-master
----SparkDemo()
--------src()
--------.settings()
--------pom.xml(2KB)
----kafka-command.txt(662B)
----spark-command.txt(195B)
----KakfaTest()
--------src()
--------.settings()
--------pom.xml(1KB)
----README.md(357B)
----students.txt(50B)
----test.csv(2KB)