程序似乎执行了很长一段时间才停止,且 linux 下 kafka 没有收到对应消息:
pom.xml 的配置和 linux 下的 kafka 是同一版本:
linux 下的防火墙已关闭,别的主机用 wget 测试似乎也能收到请求:
(测试主机)
(被测试主机)
网上的方法测了好几个,就是没法解决问题,请问我这是哪儿出了问题?
程序似乎执行了很长一段时间才停止,且 linux 下 kafka 没有收到对应消息:
pom.xml 的配置和 linux 下的 kafka 是同一版本:
linux 下的防火墙已关闭,别的主机用 wget 测试似乎也能收到请求:
(测试主机)
(被测试主机)
网上的方法测了好几个,就是没法解决问题,请问我这是哪儿出了问题?
我猜应该是连上服务器了,但是因为某种原因导致 kafka 没法接收到消息。会不会是 zookeeper 配置的问题?
window 下要不要配置 zookeeper?
我猜可能是因为 window 不在集群内吧。
15 回答8.4k 阅读
8 回答6.2k 阅读
4 回答4.4k 阅读✓ 已解决
4 回答4k 阅读
1 回答3k 阅读✓ 已解决
3 回答2.1k 阅读✓ 已解决
2 回答1.5k 阅读✓ 已解决
介绍
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、搭建与实践