Как привязать потребителя Kafka к носику Storm?

Question

Как отправить запись Consumer в объект Storm Spout в одной строке кода? У меня есть два экземпляра, один из которых - объект KafkaConsumer, а другой - объект StormSpout. Я хочу получить nextTuple из опроса Kafka Consumer для Spout с использованием объекта KafkaBolt.

Answer 1

Я думаю, что, возможно, ваше понимание немного неверно. Вы не должны создавать KafkaConsumer вручную.

Используйте KafkaSpout (или носик Trident) из модуля 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.