kafka listener配置解決Server與消費端不在同一網路問題

在kubernetes容器環境下 kafka會預設把主機名註冊到zookeeper。這個時候消費端部署在不同的命名空間或者不同的集群中會出現無法訪問的情況。用advertised.listeners配置可以重寫預設註冊的地址。

定義

listeners

listeners 配置的是kafka Server 的tcp偵聽ip地址。

advertised.listeners

該配置主要是用於把Broker的ip地址信息發佈到Zookeeper中，簡而言之就是配置的kafka的broker ip。如果你的消費端需要不同集群/網段的訪問 需要確保改地址該消費端可訪問的地址

其他這個也不一定是在容器環境下會存在 常規的機器環境下也會出現這個問題 如果broker的ip消費端訪問不到的情況下 像下麵這個異常 可以查一下這個問題。

java.net.UnknownHostException: cep-kafka
at java.net.InetAddress.getAllByName0(InetAddress.java:1281)
at java.net.InetAddress.getAllByName(InetAddress.java:1193)
at java.net.InetAddress.getAllByName(InetAddress.java:1127)

轉載請註明出處。

作者：peachyy

出處：http://www.cnblogs.com/peachyy/