【文件属性】：
文件名称：kstorm:示例代码展示了如何在 Storm 0.9.3 中使用 Kafka Spout
文件大小：15KB
文件格式：ZIP
更新时间：2021-07-04 17:00:43
Java
概述
这是一个示例存储库，展示了如何设置 Java 项目以使用KafkaSpout ，它现在是 Storm 0.9.3 版的一部分。 在撰写本文时在线的其他示例要么是错误的（过时的），要么展示了如何在本地模式下使用 KafkaSpout 但不是针对单独的 Kafka 系统的“集群模式”，或者令人困惑，因为它们添加了许多多余的东西（和在 Scala 中做例子）。 这个例子是在“做最简单的事情，可以工作”的脉络。
正确设置 pom 以便 Storm 和 Kafka 之间不兼容的日志库不会在头脑中拍摄拓扑是最困难的部分（我生命中失去了一天的时间来解决这个问题）。 所以这可能是最脆弱的部分 - 它可能会在其他系统和其他版本（过去或未来）上损坏。
这些拓扑是基于 P. Taylor Goetz 的一书的第 1 章的基本字数拓扑。
有两个版本：
一个使用内存中的SentenceSpout （取
【文件预览】：
kstorm-master
----src()
--------main()
----README.md(3KB)
----pom.xml(5KB)
----.gitignore(39B)