kafka高可靠问题验证,发现生产在多十多秒后能恢复生产,但消费始终无法消费?

发表于: 2022-05-22   最后更新时间: 2022-05-23 14:57:15   555 游览

老师好,我在测试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

发表于 2022-05-22
添加评论
你的答案

查看kafka相关的其他问题或提一个您自己的问题