KAFKA broker抛出错误请求类型18和错误请求类型16

Question

系统：

EC2实例类型: m5.2xlarge

操作系统: Ubuntu 14.04.5 LTS

内核版本: 4.4.0-1022-aws

vCPU: 8个核心

内存:32

Java版本: 1.8.0_171

我们在集群模式下运行KAFKA，包含两个kafka代理(10.0.51.1和10.0.51.2)和三个动物园管理员节点。我想升级我的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)

只有一个代理给出了这个错误。但是我的卡夫卡集群已经开始运行，我可以从所有的话题中消费和生产。

任何帮助都将不胜感激。

谢谢。

Answer 1

客户端发送ApiVersionsRequest (请求代码18)和ListGroupsRequest (请求代码16)。请参阅源代码

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