创建指向 Kafka Producer / Sample Java Code 的 Storm 拓扑答案

【问题标题】：Create a Storm topology pointing to Kafka Producer / Sample Java Code创建指向 Kafka Producer / Sample Java Code 的 Storm 拓扑
【发布时间】：2017-11-30 19:55:29
【问题描述】：

提前致谢。我只需要一个读取 kafka 生产者并处理它（螺栓）的单个 java 类（具有 Storm 拓扑的示例代码）。我知道 github 中可用的示例很少，但我对 github、maven 等还是很陌生。这对我来说很难。

还有如何确保bolt能够成功读取spout流？

非常感谢您的帮助。

谢谢

【问题讨论】：

标签： apache-kafka apache-storm

【解决方案1】：

您的问题很笼统，因此很难回答。这是 Kafka Spout 的示例 https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java

您还需要实现自己的 Bolt（使用 IRichBolt 或 BaseBolt）。

在您的主要方法中，您可以使用 TopolgoyBuilder 将它们连接在一起。像这样：https://github.com/apache/storm/blob/master/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java

WorkCount-Example 还包含在本地 (LocalCluster) 或在真正的 Storm 集群 (StormSubmitter) 中远程执行代码的代码。

希望这会有所帮助。这些示例独立于 maven/git。只需使用您喜欢的 IDE 即可运行它。

您还应该查看 Storm 网站：https://storm.apache.org/documentation/Home.html 并阅读“基本原理”、“教程”、“设置开发环境”和“创建新的 Storm 项目”页面。

【讨论】：

非常感谢您的帮助