Kafka вычитка из топика --from-beginning

Есть кафка кластер из 6 серверов(3 брокера, 3 зукипера). Топики создаются с одной партицией и 3 репликейшн фактором. При попытке вычитки из топика ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic --offset 0 --partition 0 Все отображается красиво, но если пытаюсь сделать ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic --from-beginning то получаю просто зависание и вычитать ничего не могу.

Кафка версии ./kafka-topics.sh --version 2.5.0 (Commit:66563e712b0b9f84)

Подскажите, пожалуйста, возможно пропущены какие-то настройки в конфигах, почему нельзя сделать вычитку --from-beginning?

Аналогично при вычитке пайтоном from kafka import TopicPartition, KafkaConsumer consumer = KafkaConsumer(auto_offset_reset='smallest', bootstrap_servers='kafkabrkdev1:9092') #consumer.assign([TopicPartition('out.Loan.ScheduleAndAmounts', 0)]) msg = next(consumer) for msg in consumer: print (msg)

Работает только при добавлении строки с указанием партиции consumer.assign([TopicPartition('out.Loan.ScheduleAndAmounts', 0)])