上周开发了一个功能，需要使用kafka接上游数据并入库，本地开发时，自己安装了一个kafka服务，开发测试时使用本地的kafka服务给主题发消息，然后在自己本地的代码中进行调试。使用的kafka版本如下：
客户端：
服务端：
本地消息的接收，消费者的连接没有任何问题，然而发布到生产环境后就一直报错：
查了许久怀疑可能是版本问题，于是查看服务端版本：
总结：本地客户端版本是0.10.1.1，服务端版本是2.4.1。没问题可以接收，环境上服务端版本是0.10.0.1，消费者无法连接。最后将客户端版本与服务端改成一致的，问题解决。
使用kafka最好客户端版本和服务端保持一致！