上周開發了一個功能，需要使用kafka接上游數據並入庫，本地開發時，自己安裝了一個kafka服務，開發測試時使用本地的kafka服務給主題發消息，然后在自己本地的代碼中進行調試。使用的kafka版本如下：
客戶端：
服務端：
本地消息的接收，消費者的連接沒有任何問題，然而發布到生產環境后就一直報錯：
查了許久懷疑可能是版本問題，於是查看服務端版本：
總結：本地客戶端版本是0.10.1.1，服務端版本是2.4.1。沒問題可以接收，環境上服務端版本是0.10.0.1，消費者無法連接。最后將客戶端版本與服務端改成一致的，問題解決。
使用kafka最好客戶端版本和服務端保持一致！