這個問題是同事遇到的：

錯誤信息：
ERROR Error when sending message to topic test with key: null, value: 5 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for test-0

原先使用的是0.8.1.1版本的kafka，換成0.10.0.1版本的kafka之后，仍然使用之前創建的topic ?test，就會一直出現這個錯誤。
當我使用新版本的kafka創建一個新的topic，進行測試，發現問題就沒有了。判定是兩個版本的topic不能通用，代碼可能實現不一致導致的。

配置：offsets.topic.replication.factor=1
The reason was successfully found in logs : Number of alive brokers '1' does not meet the required replication factor '3' for the offsets topic you need to post into your server.properties file following option : offsets.topic.replication.factor=1. This option will not let you do anything till the count reaches 3 but since you have it set as a playbox - you usually have 1 only.

延申：

1.檢查各個broker的機器上的jdk版本，最好保持一致

2.檢查各個zookeeper版本，要求一致

3.檢查kafka版本，要求一致。

總結

以上是生活随笔為你收集整理的kafka版本 不对问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。