在kafka的server.log中发现了如下报错信息:
| 1 2 3 4 5 6 7 8 9 10 11 | 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) | 
在StackOverflow上找到了类似的问题。知道报这个错的是因为kafka服务端的版本和kafka客户端的版本不一致导致的。
解决方案很简单:
- 调整kafka server端版本;
- 调整kafka客户端版本。
#######
发表评论