kafka listener配置解決Server與消費端不在同一網路問題
阿新 • • 發佈：2022-05-24
在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)