在哪里可以找到storm kafka（Kafka喷口）拓扑工作示例？

Question

在新版本的Storm（0.9.2）有一个内置的Kafka喷口基于https://github.com/apache/incubator-storm/tree/v0.9.2-incubating有很多例子如何使用这个Kafka喷口在网上，但看起来像是有什么改变未知的声明。

例如：

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

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

Answer 1

我没有任何Kafka的经验，我也在尝试，但你可能想尝试下面的代码片段，以克服所述的问题：

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

Answer 2

您可以查看此链接：集成Kafka和Storm。作者说KafkaStorm启动项目应该包含你可以在自己的项目中使用的例子。他说他们使用的StormKafka喷口和Storm0.9.2中的一样。不过，我还没有测试过。