Мы используем потоки Kafka для записи данных в тему приемника. Я запускаю командную строку avro-consumer, чтобы проверить, есть ли данные в теме приемника:
bin / kafka-avro-console-consumer --topicink.output.topic --from-begin --new-consumer --bootstrap-server
Я вижу данные, когда я одновременно запускаю потребителя во время работы приложения потоков kafka, но если я останавливаю потребителя и снова запускаю его через несколько минут, я не вижу никаких данных. Несколько возможностей:
1) Это потому, что потоки kafka стирают записи из выходной темы каждый раз, когда они подталкивают записи к опусканию?
2) Или это просто проблема потребителя?
