如何将 Kafka 消费者绑定到 Storm spout？

Question

如何在一行代码中将消费者记录发送到 Storm Spout 对象？我有两个实例，其中一个是 KafkaConsumer 对象，另一个是 StormSpout 对象。我想使用KafkaBolt对象将来自Kafka Consumer民意调查的nextTuple获取到Spout。

Answer 1

我想你的理解可能有点错误。您不应该手动创建 KafkaConsumer。

使用org.apache.storm:storm-kafka-client 模块中的KafkaSpout（或Trident spout）。您可以在 https://storm.apache.org/releases/2.0.0-SNAPSHOT/storm-kafka-client.html 的 Storm 文档中找到有关如何使用它的指南，并在 https://github.com/apache/storm/tree/master/examples/storm-kafka-client-examples 找到示例代码。