KAFKA经纪人抛出错误的请求类型18和错误的请求类型16

Question

系统:
EC2实例类型:m5.2xlarge
操作系统:Ubuntu 14.04.5 LTS
内核版本:4.4.0-1022-aws
vCPU:8内核
内存:32Gib

Java版本:1.8.0_171

我们在集群模式下运行KAFKA,有两个kafka代理(10.0.51.1和10.0.51.2)和三个zookeeper节点.我想升级我的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)

只有1个经纪人提供此错误.但我的KAFKA集群已启动并运行,我可以使用所有主题进行消费和生成.

任何帮助,将不胜感激.

谢谢.

Answer 1

客户端发送了一个ApiVersionsRequest（请求代码18）和一个ListGroupsRequest（请求代码16）。查看源代码

升级后，可能并非所有经纪人/消费者/生产者都使用相同的版本。您能否验证并调整版本？新客户端应该能够与旧版本进行通信，因此您的代码中使用的库可能较旧。