Kafka问题:Exception in thread "Thr

2019-01-29  本文已影响0人  Sam_L
问题产生背景:

在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

上一篇 下一篇

猜你喜欢

热点阅读