程序似乎执行了很长一段时间才停止,且 linux 下 kafka 没有收到对应消息:
pom.xml 的配置和 linux 下的 kafka 是同一版本:
linux 下的防火墙已关闭,别的主机用 wget 测试似乎也能收到请求:
(测试主机)
(被测试主机)
网上的方法测了好几个,就是没法解决问题,请问我这是哪儿出了问题?
kafka
的 2 个参数配置。listener
:kafka broker 监听器;
advertised.listeners
:用于注册到 zookeeper
上面的 kafka
监听器。如果该值未填写,那么会使用 listener
的值。
kafka
通信?listener
配置的地址,连上 kafka
,完成认证。会返回一个地址。advertised.listeners
的值。假设一:部署在 linux
中的 kafka
不在 docker
内。是直接部署在 linux
上面。
从已知信息来看,windows
和 linux
已经能够连接上了。linux
中能够正常消费,这证明,kafka
和 zookeeper
没毛病。
然后我想确认一下。listener
配置的是哪个? 也就是,listener
你需要填写 linux
主机的 ip
假设二:kafka
部署在 linux
上的 docker 内。
这部分的内容,请参考本人写的如何在 docker
中搭建 kafka
kafka 系列 -- 2、搭建与实践