我在哪里可以找到风暴Kafka(Kafka喷口)拓扑工作的例子？

sh7euo9m 于 2021-06-21 发布在 Storm

关注(0)|答案(2)|浏览(363)

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

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

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

bigdata apache-storm cloud

来源：https://stackoverflow.com/questions/24484957/where-can-i-find-storm-kafka-kafka-spout-topology-working-example

2条答案

按热度按时间

rseugnpd1#

你可以查看这个链接：整合Kafka和风暴。作者说，Kafka风暴初学者项目应该包含的例子，你可以在自己的项目中使用。他说他们使用的风暴Kafka喷口和风暴0.9.2中的喷口是一样的。但是，我还没有测试它。

赞(0）回复(0）举报 2021-06-21

w7t8yxp52#

我对Kafka没有任何经验，我也在尝试，但您可能希望尝试下面的代码片段来克服所述问题：

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

赞(0）回复(0）举报 2021-06-21

我来回答

我在哪里可以找到风暴Kafka(Kafka喷口)拓扑工作的例子？

2条答案

相关问题

热门标签

最新问答