问题产生背景:
在IDEA下执行kafka java API 编程测试的时候,反复确认过,定义的ZK和BROKER_LIST 的ip地址,TOPIC都写正确了,并且服务器端已经开启了zookeeper和kafka,也启动了一个consumer,一切都很正确,
但是。。。运行测试的时候就报错:
image.png
错误的原因排查后确定:
需要修改kafka配置$KAFKA_HOME/config/server.properties
解决
之前设置的都不用改变例如host.name=hadoop001
只需在下面添加一句话
advertised.host.name=你的ip地址
保存,重新启动kafka,consumer,然后运行IDEA,OK~
【host.name】开始只绑定在了内部IP上,对外网无法访问
【advertised.host.name】参数用来配置返回的host.name值,把这个参数配置为外网IP地址即可
关于advertised.host.name可以参考这篇文档
https://www.cnblogs.com/snifferhu/p/5102629.html
网友评论