kafka代理抛出错误的请求类型18和错误的请求类型16

20jt8wwn  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(307)

系统:
ec2示例类型:m5.2xlarge
操作系统:ubuntu 14.04.5 lts
内核版本:4.4.0-1022-aws
vcpu:8芯
内存:32gib
java版本:1.8.0«
我们使用两个kafka代理(10.0.51.1和10.0.51.2)和三个zookeeper节点以集群模式运行kafka。我想升级我的aws ec2示例,所以我运行了 sudo apt-get update 以及 sudo apt-get upgrade 并已安装 linux-aws 内核。更改示例类型后,我的10.0.51.2 kafka borker中出现以下错误:

18/06/08 07:03:50 52902420 [kafka-network-thread-9092-0] ERROR kafka.network.Processor - Closing socket for /10.0.51.1 because of error
kafka.common.KafkaException: Wrong request type 18
    at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
    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:748)
18/06/08 07:03:50 52902571 [kafka-network-thread-9092-2] ERROR kafka.network.Processor - Closing socket for /10.0.51.1 because of error
kafka.common.KafkaException: Wrong request type 16
    at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
    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:748)

只有一个代理给出了这个错误。但我的Kafka集群已经启动并运行,我可以从所有主题中消费和生产。
任何帮助都将不胜感激。
谢谢。

4xrmg8kj

4xrmg8kj1#

客户端发送了一个 ApiVersionsRequest (请求代码18)和 ListGroupsRequest (请求代码16)。请参阅源代码
可能不是所有的代理/消费者/生产者在升级后都使用相同的版本。你能核实一下版本吗?新客户机应该能够与旧版本通信,因此代码中使用的库可能是旧的。

相关问题