У меня есть 2 топологии кафкасторма, в которых топология кафки-производителя считывает данные из оплога mongodb и добавляет к теме кафки, и хорошо, что она работает абсолютно нормально!
Хотя топология kafka-customer (Kafkaspout) не извлекает все данные из определенной темы. более 98% записей терпят неудачу на стороне потребителя.
Все записи по теме должны быть использованы kafkaSpout. Любое предложение плз!