如何在一行代码中将消费者记录发送到storm spout对象？我有两个示例，一个是kafkaconsumer对象，另一个是stormspout对象。我想得到来自kafka消费者调查的下一个tuple来使用kafkabolt对象。
mbzjlibv1#
我想也许你的理解有点错误。你不应该手动创建一个Kafka消费者。使用kafkaspout（或三叉戟喷口）从 org.apache.storm:storm-kafka-client 模块。您可以在storm文档中找到如何使用它的指南https://storm.apache.org/releases/2.0.0-snapshot/storm-kafka-client.html，以及https://github.com/apache/storm/tree/master/examples/storm-kafka-client-examples.
org.apache.storm:storm-kafka-client
1条答案
按热度按时间mbzjlibv1#
我想也许你的理解有点错误。你不应该手动创建一个Kafka消费者。
使用kafkaspout（或三叉戟喷口）从
org.apache.storm:storm-kafka-client模块。您可以在storm文档中找到如何使用它的指南https://storm.apache.org/releases/2.0.0-snapshot/storm-kafka-client.html，以及https://github.com/apache/storm/tree/master/examples/storm-kafka-client-examples.