文件名称:kstorm:示例代码展示了如何在 Storm 0.9.3 中使用 Kafka Spout
文件大小:15KB
文件格式:ZIP
更新时间:2024-07-24 10:47:23
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)