
kafka org.apache.kafka.common.errors.TimeoutException
原因是发布到zookeeper的advertised.host.name如果没有设置,默认取java.net.InetAddress.getCanonicalHostName().值,被用于生产端和消费端。因此外部网络或者未配置hostname映射的机器访问kafka集群时就会有网络问题了。原因是kafka客户端连接到broker是成功的,但连接到集群后更新回来的集群meta信息是错误的即是会..
·
原因是发布到zookeeper的advertised.host.name如果没有设置,默认取java.net.InetAddress.getCanonicalHostName().
值,被用于生产端和消费端。因此外部网络或者未配置hostname映射的机器访问kafka集群时就会有网络问题了。
原因是kafka客户端连接到broker是成功的,但连接到集群后更新回来的集群meta信息是错误的即是会返回的是节点的hostname,解决办法就是手动配置advertised.host.name和advertised.port,2个参数都必须配置,重启问题解决:
估计读者们也会跟我一样犯迷糊,为什么需要三个参数来配置IP和端口号呢,用一个advertised.listeners
不就搞定了吗?
后来发现最新版本0.10.x broker配置弃用了advertised.host.name
和 advertised.port
这两个个配置项,就配置advertised.listeners就可以了。
最新版是listeners
更多推荐
所有评论(0)