kafka_2.11-0.10.1.1 无法发送消息和消费消息

发布于 2021-12-03 21:56:19 字数 406 浏览 838 评论 8

异常现象如下:

[2017-02-07 15:23:54,323] ERROR Error when sending message to topic test with key: null, value: 5 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

 

最近打算将中间件迁移到kafka,新搭的集群环境kafka+zookeeper集群,发送消息总是报这个错,网上也没有找到解决方案,就想问问这里的兄弟们有熟悉这个的吗

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(8

多情癖 2021-12-06 15:20:56

I would say,it's impossible!

英雄似剑 2021-12-06 15:20:40

问题已找到,应该是kafka的机制问题,之前我是kafka集群放在腾讯云上,然后我把9092端口映射出来,kafka在使用的时候是会随机分配一个端口来发送和接收消息,所以结论是最好在同一局域网内,所有端口都开放。

看透却不说透 2021-12-06 15:20:18

我的hosts里面第一条都是127.0.0.1 localhost,这个有关系吗?

用的是3台服务器做的集群, 用程序获取到的机器名是localhost,是因为这个原因吗,

配置我是这样配的

listeners=PLAINTEXT://ip:9092

zookeeper.connect=ip1:2181,ip1:2181,ip1:2181

怎言笑 2021-12-06 15:19:26

用IP的,这个必须是机器名吗

梦里兽 2021-12-06 15:02:52

回复
@youarepp : 不知道你的配置和部署情况,kafka集群默认返回的是机器名,所以要保证客户端到服务器之间可以通过机器名联通; 另外,进看你给的这两条信息不能确定是这个问题,比如也可能你指定的地址错 了

好听的两个字的网名 2021-12-06 14:24:40

我的hosts里面第一条都是127.0.0.1 localhost,这个有关系吗? 用的是3台服务器做的集群, 用程序获取到的机器名是localhost,是因为这个原因吗, 配置我是这样配的 listeners=PLAINTEXT://ip:9092 zookeeper.connect=ip1:2181,ip1:2181,ip1:2181

清欢 2021-12-06 04:21:39

回复
@youarepp : 那必须修改配置hosts文件,把三台机器的ip和hostname的对应关系都加进去。 或者也可以修改kafka配置文件,advertised.host.name=192.xxx 这样让kafka返回给客户端ip而不是机器名

风苍溪 2021-12-05 20:18:29

信息不够,猜一下,没配hosts?

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文