Kafka報錯：Error reading field ‘topics’

摘要： 在kafka的server.log中發現瞭如下報錯資訊： ERROR Closing socket for /xxx.xxx.xxx.xxx because of error (kafka.network.Processor) org.apache.kafka.common.protoco...

在kafka的server.log中發現瞭如下報錯資訊：

ERROR Closing socket for /xxx.xxx.xxx.xxx because of error (kafka.network.Processor)
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topics': java.nio.BufferUnderflowException
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:66)
at org.apache.kafka.common.requests.JoinGroupRequest.parse(JoinGroupRequest.java:85)
at kafka.api.JoinGroupRequestAndHeader$.readFrom(JoinGroupRequestAndHeader.scala:29)
at kafka.api.RequestKeys$$anonfun$12.apply(RequestKeys.scala:50)
at kafka.api.RequestKeys$$anonfun$12.apply(RequestKeys.scala:50)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)

在ofollow,noindex">StackOverflow 上找到了類似的問題。知道報這個錯的是因為kafka服務端的版本和kafka客戶端的版本不一致導致的。

解決方案很簡單：

• 調整kafka server端版本；
• 調整kafka客戶端版本。

#######