Когда я использую:
bin/kafka-console-consumer.sh --consumer.config kafka.properties --bootstrap-server myBroker1:6643,myBroker2:6643 --topic myTopic --from-beginning
Я получаю примерно один день сообщений, несмотря на то, что в моих журналах хранится 168 часов, а размер не ограничен.
Что я делаю не так?