producer properties тоже?
и тоже самое для чтения - комманда и consumer properties?
Включен ли у вас unclean.leader.election.enable? и что стоит в min.insync.replicas?
настройки дефолтные, ничего не менял, кроме двух параметров что описал выше. пишу/читаю родными средствами kafka-console-producer.sh --broker-list 192.168.56.11:9092,192.168.56.12:9092,192.168.56.13:9092 --topic test kafka-console-consumer.sh --bootstrap-server 192.168.56.12:9092,192.168.56.11:9092,192.168.56.13:9092 --consumer-property group.id=group1 --topic test
Обсуждают сегодня