网站建设 管理 会议纪要大连工业大学宿舍

前置条件：

• 已在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映射，

1.         在C:\Windows\System32\drivers\etc\hosts
2.         加上114.xxx.xx.223 VM-16-17-centos，保存编辑
3.         重启客户端

        kafka服务容器配置解决（建议方案）

1.                 登录kafka服务器，进入kafka安装目录，编辑config/server.properties文件
2.                 新增配置项：advertised.listeners=PLAINTEXT: //114.xxx.xx.223:9092
3.       重新启动kafka服务,再重启客户端