如何修改Kafka Broker列表IP？VIP连接集群返回混合IP致失败

这个问题我之前在隔离网络环境部署Kafka时也碰到过，核心原因是Kafka Broker默认会把自身内部监听的IP地址注册到集群元数据（ZooKeeper或KRaft日志）中。当客户端通过VIP连接bootstrap server后，Broker会把这些内部IP返回给客户端，但客户端处于隔离区外无法访问这些内部IP，自然就连接失败了。

下面给你分步解决这个问题，同时说明如何修改Broker对外暴露的IP列表：

不管你用的是ZooKeeper还是KRaft模式，关键都是修改每个Broker的server.properties配置，让Broker把VIP地址注册到元数据中，而不是内部IP。

针对每个Broker的配置修改 #

找到每个Broker的server.properties文件，修改以下两个关键配置（注意每个Broker要对应自己的内部IP和VIP）：

1. listeners：Broker内部监听的地址 #

这个配置是Broker用来接收集群内部其他Broker、副本同步等请求的地址，填自己的内部IP：

# 比如10.5.1.5的Broker，配置如下
listeners=PLAINTEXT://10.5.1.5:9092

2. advertised.listeners：Broker对外暴露给客户端的地址 #

这个是核心！填对应的VIP地址，客户端会从元数据中拿到这个地址进行连接：

# 对应10.5.1.5的VIP是200.100.1.5，配置如下
advertised.listeners=PLAINTEXT://200.100.1.5:9092

重启Broker并验证 #

• 逐个重启每个Broker（避免集群不可用），重启命令参考：

# 停止Broker
bin/kafka-server-stop.sh
# 启动Broker（后台运行）
bin/kafka-server-start.sh -daemon config/server.properties

• 验证：用Kafka自带工具测试连接，比如查看topic列表：

bin/kafka-topics.sh --bootstrap-server 200.100.1.5:9092 --list

如果能正常返回topic列表，再可以用客户端工具查看元数据，确认返回的Broker地址全都是VIP，没有内部IP。

其实上面的advertised.listeners配置就是用来修改Broker对外暴露的IP列表的。每个Broker配置好自己的VIP后，集群元数据中就会存储这些VIP地址，客户端连接任意一个bootstrap VIP后，都会拿到所有Broker的VIP地址，自动进行负载均衡和故障转移。

• 确保VIP和内部IP的端口一致（比如都是9092），如果有端口映射，要在配置中对应修改端口号。
• 如果你的集群启用了安全协议（比如SSL），要把PLAINTEXT换成对应的协议（比如SSL），同时配置好对应的证书等。

内容的提问来源于stack exchange，提问作者Jack