kafka broker抛出schemaexception:读取字段主题时出错(使用kafka管理器)

kyxcudwk  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(242)

在kafka(0.8.2.1)集群中使用kafka管理器(1.3.1.*)时,出现以下异常。

ERROR Closing socket for /XX.XX.XX.XX 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:74

通过查看异常,可以推断kafka manager和broker之间存在版本不匹配。
在kafka管理器ui中,我给出了一个类似于broker的版本,但我还是得到了这个。
我还发现kafka管理器正在使用org.apache.kafka.kafka-clients-0.9.0.1.jar,org..apache.kafka.kafka\u 2.11-0.9.0.1.jar。
那么,如何解决这个问题呢?Kafka管理器中是否有任何参数来指定Kafka·伯克的版本或它是一个bug?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题