這個(gè)問(wèn)題是同事遇到的：

錯(cuò)誤信息：
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之后，仍然使用之前創(chuàng)建的topic ?test，就會(huì)一直出現(xiàn)這個(gè)錯(cuò)誤。
當(dāng)我使用新版本的kafka創(chuàng)建一個(gè)新的topic，進(jìn)行測(cè)試，發(fā)現(xiàn)問(wèn)題就沒(méi)有了。判定是兩個(gè)版本的topic不能通用，代碼可能實(shí)現(xiàn)不一致導(dǎo)致的。

配置：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.檢查各個(gè)broker的機(jī)器上的jdk版本，最好保持一致

2.檢查各個(gè)zookeeper版本，要求一致

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

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。