Я работал вГроза и разработал базовую программу, которая использует локальный текстовый файл в качестве источника ввода. Но теперь я должен работать над потоковой передачей данных, поступающих непрерывно из внешних систем. Для этой цели Кафка - лучший выбор.

Проблема в том, как заставить мой Spout получать потоковые данные от Kafka. Или как интегрировать Storm с Kafka. Как я могу это сделать, чтобы обрабатывать данные, поступающие с Kafka?