一、問題描述
今天配合現場聯調一個數據工具,工具使用到了kafka,程序啟動之后包如下錯誤:
[WARN ] [2020-08-17 19:17:27] [org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeHandleDisconnection(NetworkClient.java:568)] Bootstrap broker 32.96.142.216:2181 disconnected
[WARN ] [2020-08-17 19:17:27] [org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeHandleDisconnection(NetworkClient.java:568)] Bootstrap broker 32.96.142.216:2181 disconnected
[WARN ] [2020-08-17 19:17:27] [org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeHandleDisconnection(NetworkClient.java:568)] Bootstrap broker 32.96.142.216:2181 disconnected
[WARN ] [2020-08-17 19:17:27] [org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeHandleDisconnection(NetworkClient.java:568)] Bootstrap broker 32.96.142.216:2181 disconnected
[WARN ] [2020-08-17 19:17:28] [org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeHandleDisconnection(NetworkClient.java:568)] Bootstrap broker 32.96.142.216:2181 disconnected
[WARN ] [2020-08-17 19:17:28] [org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeHandleDisconnection(NetworkClient.java:568)] Bootstrap broker 32.96.142.216:2181 disconnected
這個錯誤之前遇到過,還寫過博客,是客戶端版本和服務端不匹配導致的,於是便檢查jar包中客戶端版本服務端版本是否一致,檢查發現是一致的,頓時不知道原因所在,后又更換各種版本進行測試發現,還是不行,其它版本啟動不會報錯,但是由於版本不匹配無法監聽到topic中的消息,時間一分一秒的流逝,正當我一籌莫展之時,發現現場同事配置的端口是2181,恍然大悟,2181是zookeeper的默認端口,kafka一般為9092,於是檢查kafka的server.properties文件,發現端口的確為9092。
二、解決方法
修改kafka配置broker的端口為9092