前置条件:
- 已在CentOs上搭建好kafka节点服务器,已启动kafka服务
- 已在Springboot项目中引入kafka客户端配置,kafka.bootstrap-server=ip:port,并启动客户端服务
异常过程:
在客户端Springboot服务启动过程,控制台抛出异常信息: Can't resolve address: VM-12-16-centos:9092
原因分析:
当kafka broker启动时,会向zookeeper注册自己的IP+PORT,客户端通过这个ip:port地址进行连接
在AWS这种IaaS环境下,由于kafka是基于jdk运行,它通过java.net.InetAddress.getCanonicalHostName
调用拿到的HostName是主机名,所以默认注册到ZK上的是主机名(VM-12-16-centos) ,而不是宿主服务器ip地址,所以注册到zookeeper中的地址是VM-12-16-centos:9092
因此,在客户端通过ip:port进行连接时,请求会到达宿主机,因为容器配置了端口映射,所以请求会被转发到监听对应端口的容器中,容器中没有找到ip:port的地址,所以返回了异常信息
解决方案:
客户端主机解决(临时方案)
既然kafka服务注册到zookeeper的地址是VM-12-16-centos:9092,那么我们可以在客户端的主机上的host文件中添加ip映射,
- 在C:\Windows\System32\drivers\etc\hosts
- 加上114.xxx.xx.223 VM-16-17-centos,保存编辑
-
重启客户端
kafka服务容器配置解决(建议方案)