Почему kafka-console-consumer.sh не возвращает сообщения из всех доступных журналов с --from-begin? - PullRequest
0 голосов
/ 26 сентября 2019

Когда я использую:

bin/kafka-console-consumer.sh --consumer.config kafka.properties --bootstrap-server myBroker1:6643,myBroker2:6643 --topic myTopic --from-beginning

Я получаю примерно один день сообщений, несмотря на то, что в моих журналах хранится 168 часов, а размер не ограничен.

Что я делаю не так?

...