springboot整合kafka bootstrap-servers设置多个ip

Care。 发表于: 2020-12-23   最后更新时间: 2020-12-23  

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 stream分布式
下一条: kafka如何修改topic的分区数

  • 先查看一下你的kafka主题有几个副本,如果是单个副本,出现这种是正常的,没有其他副本了。
    如果是多个副本,你这个问题可能就不会出现了。

    ## 查询集群描述
    bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181
    

    先确认下这个吧。