Я пытаюсь интегрировать MongoDB и Storm-Kafka, Kafka Producer производит данные из MongoDB, но не может извлечь их со стороны потребителя.
Версия Kafka: 0.10. * Версия Storm: 1.2.1
Нужно ли добавлять какие-либо функции в Consumer?