Проблемы - обновление kafka с 3.3.3 до пакета 5.4.1 - PullRequest
Новая
       67

Проблемы - обновление kafka с 3.3.3 до пакета 5.4.1

0 голосов
/ 27 апреля 2020

В настоящее время я использую kafka версии 0.11.x (3.3.3 версии пакета confluent), я обновил до версии 2.4.x kafka (5.4.1 confluent package). Я вижу странную проблему В оболочке zookeeper я могу перечислить идентификаторы брокера / контроллер и т. Д. c, а также увидеть список zookeeper в свойствах сервера. Но у меня при репликации для всех тем и журналов упоминается ошибка ниже 1. Журнал сервера: 

[2020-04-27 11:35:51,372] INFO [ZooKeeperClient ACL authorizer] Initializing a new session to tran-1.zookeeper:2181,tran.zookeeper:2181,tran-3.zookeeper:2181. (kafka.zookeeper.ZooKeeperClient)
[2020-04-27 11:35:51,373] INFO [ZooKeeperClient ACL authorizer] Waiting until connected. (kafka.zookeeper.ZooKeeperClient)
[2020-04-27 11:35:51,374] ERROR [ZooKeeperClient ACL authorizer] Auth failed. (kafka.zookeeper.ZooKeeperClient)
[2020-04-27 11:35:51,388] INFO [ZooKeeperClient ACL authorizer] Connected. (kafka.zookeeper.ZooKeeperClient)

В нем упоминается ОШИБКА "Auth Failed", но затем в следующей строке упоминается, что он подключен.

Журнал контроллера Kafka упоминает: 
WARN [RequestSendThread controllerId=3] Controller 3's connection to broker tran-2.kafka.test.local:9093 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread)
java.io.IOException: Connection to tran-2.kafka.test.local:9093 (id: 2 rack: null) failed.
       at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
       at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296)
       at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:250)
       at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)

Я постоянно получаю это ПРЕДУПРЕЖДЕНИЕ, записываемое в журналы контроллера.

Может кто-нибудь сообщить мне, что я здесь упускаю или как решить или go к решению.

...