1. 程式人生 > >kafka連線後使用的是主機名導致連線失敗

kafka連線後使用的是主機名導致連線失敗

當Kafka broker啟動時,它會在ZK上註冊自己的IP和埠號,客戶端就通過這個IP和埠號來連線。

在AWS這種IaaS環境下,由於java.net.InetAddress.getCanonicalHostName呼叫拿到的HostName是主機名,所以預設註冊到ZK上的是主機名

需要配置server.properties

advertised.listeners=PLAINTEXT://192.168.16.11:9092