Брокер KAFKA, выбрасывающий неправильный тип запроса 18 и неправильный тип запроса 16 - PullRequest
Новая
       9

Брокер KAFKA, выбрасывающий неправильный тип запроса 18 и неправильный тип запроса 16

0 голосов
/ 08 июня 2018

System :Тип экземпляра EC2: m5.2xlargeОС: Ubuntu 14.04.5 LTSВерсия ядра: 4.4.0-1022-awsvCPU: 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 запущен и работает, я могу использовать его по всем темам.

Любая помощь будет признательна.

Спасибо.

1 Ответ

0 голосов
/ 08 июня 2018

Клиент отправил ApiVersionsRequest (код запроса 18) и ListGroupsRequest (код запроса 16).см. исходный код

Возможно, не все брокеры / потребители / производители используют одну и ту же версию после обновления.Можете ли вы проверить и при необходимости выровнять версии?новые клиенты должны иметь возможность общаться со старой версией, поэтому, вероятно, используемая в вашем коде библиотека старше.

...