在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客户端版本。
#######
发表评论