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

【问题标题】：KAFKA broker throwing Wrong request type 18 and Wrong request type 16KAFKA 经纪人抛出错误的请求类型 18 和错误的请求类型 16
【发布时间】：2018-11-18 06:13:09
【问题描述】：

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

Java 版本：1.8.0_171

我们使用两个 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)

只有 1 个代理出现此错误。但是我的 KAFKA 集群已经启动并运行，我可以消费和生产所有主题。

任何帮助将不胜感激。

谢谢。

【问题讨论】：

标签： amazon-web-services amazon-ec2 apache-kafka apache-zookeeper

【解决方案1】：

客户端发送了一个ApiVersionsRequest（请求代码18）和一个ListGroupsRequest（请求代码16）。见source code

可能并非所有代理/消费者/生产者在升级后都使用相同的版本。您能否验证并以防万一对齐版本？新客户端应该能够与旧版本通信，因此您的代码中使用的库可能较旧。

【讨论】：