老师好,我在测试kafka的时候遇到一个问题,想请教下是否我使用的方式不对。
我搭建了kafka集群 kafka01 kafka02 kafka03,并创建了一个topic 。
kafka-topics.sh --create --zookeeper kafka01:2181,kafka02:2181,kafka03:2181 --replication-factor 3 --partitions 1 --topic wlz_test
接着通过 自带生产者和消费者脚本测试生产和消费。
下面是消费语句:
kafka-console-consumer.sh --bootstrap-server kafka02:9092,kafka03:9092 --topic wlz_test --from-beginning --group 'test-consumer-group
单我把kafka01 节点停掉以后,发现生产在多十多秒后能恢复生产,但消费始终无法消费。
除非我把group改成其他名字,请问有老师知道这是什么原因吗?
我理解的高可靠应该 生产和消费 都能恢复才对。使用的kafka版本是 2.8.1
参考这篇文章,也是你的原因:kafka高可用失败问题 3broker,单杀一个broker就不能消费的问题探讨
你的答案