系统:
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集群已经启动并运行,我可以从所有主题中消费和生产。
任何帮助都将不胜感激。
谢谢。
1条答案
按热度按时间4xrmg8kj1#
客户端发送了一个
ApiVersionsRequest
(请求代码18)和ListGroupsRequest
(请求代码16)。请参阅源代码可能不是所有的代理/消费者/生产者在升级后都使用相同的版本。你能核实一下版本吗?新客户机应该能够与旧版本通信,因此代码中使用的库可能是旧的。