kafka版本是2.4.1。
springboot整合kafka bootstrap-servers 设置多个kafka用,
隔开,其中一个宕机springboot处理发送消息会卡住。
bootstrap-servers: 172.16.0.146:9092,172.16.0.147:9092,172.16.0.148:9092
我将172.16.0.146:9092
关掉 后续消费之和生产者在java服务中会卡住,但172.16.0.147:9092,172.16.0.148:9092
会收到消息
重新开启后又能正常收发消息,之前宕机时候发送的消息也存在,这个符合kafka集群的策略吗?
我该怎么做,在172.16.0.146:9092
宕机时候也能正常发送消息,不会等待异步调用?
先查看一下你的kafka主题有几个副本,如果是单个副本,出现这种是正常的,没有其他副本了。
如果是多个副本,你这个问题可能就不会出现了。
## 查询集群描述 bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181
先确认下这个吧。
是单副本正在改进 谢谢大佬
你的答案