我在哪里可以找到storm-kafka（kafka spout）拓扑工作示例？答案

【问题标题】：Where can I find storm-kafka (kafka spout) topology working example?我在哪里可以找到storm-kafka（kafka spout）拓扑工作示例？
【发布时间】：2014-06-30 07:29:31
【问题描述】：

在新版本的storm（0.9.2）中有一个基于https://github.com/apache/incubator-storm/tree/v0.9.2-incubating的内置kafka spout 网上有很多关于如何使用这个 kafka spout 的例子，但看起来有些东西已经改变了。大多数示例都不起作用，由于未知声明导致许多错误。

例如：

BrokerHosts brokerHosts = KafkaConfig.StaticHosts.fromHostString(
                ImmutableList.of("localhost"), 1);

编译器无法识别“StaticHosts”，KafkaConfig 类不包含它。

【问题讨论】：

标签： cloud bigdata apache-storm

【解决方案1】：

您可以查看此链接：Integrating Kafka and Storm。作者说kafka-storm-starter 项目应该包含您可以在自己的项目中使用的示例。他说他们使用的storm-kafka spout与storm 0.9.2中的相同。但是，我还没有测试过。

【讨论】：

【解决方案2】：

我对 Kafka 没有任何经验，我也在尝试，但您可能想尝试下面的代码 sn-p 来解决上述问题：

GlobalPartitionInformation partitionInformation = new GlobalPartitionInformation();
partitionInformation.addPartition(0, Broker.fromString("localhost"));
BrokerHosts host = new StaticHosts(partitionInformation );

【讨论】：