кафка не работает для меня, используя в первый раз отказ в подключении .ZooKeeperClient

#java #sockets #cmd #apache-zookeeper #apache-kafka-streams

Вопрос:

я устанавливаю кафку в первый раз. я хочу начать это . когда я бегу .binwindowsкафка-сервер-запуск.bat .конфигурациясервер.свойства я получаю этот результат

 [2021-10-08 10:03:43,563] INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused: no further information (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:44,693] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:46,743] INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused: no further information (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:47,873] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:49,928] INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused: no further information (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:51,043] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:53,093] INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused: no further information (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:54,233] INFO Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:56,283] INFO Socket error occurred: localhost/127.0.0.1:2181: Connection refused: no further information (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:57,403] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:59,443] INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused: no further information (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:59,523] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient)
[2021-10-08 10:03:59,683] INFO Session: 0x0 closed (org.apache.zookeeper.ZooKeeper)
[2021-10-08 10:03:59,693] INFO EventThread shut down for session: 0x0 (org.apache.zookeeper.ClientCnxn)
[2021-10-08 10:03:59,708] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient)
[2021-10-08 10:03:59,713] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
        at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:271)
        at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:125)
        at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1948)
        at kafka.server.KafkaServer.createZkClient$1(KafkaServer.scala:431)
        at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:456)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:191)
        at kafka.Kafka$.main(Kafka.scala:109)
        at kafka.Kafka.main(Kafka.scala)
[2021-10-08 10:03:59,723] INFO shutting down (kafka.server.KafkaServer)
[2021-10-08 10:03:59,743] INFO App info kafka.server for 0 unregistered (org.apache.kafka.common.utils.AppInfoParser)
[2021-10-08 10:03:59,743] INFO shut down completed (kafka.server.KafkaServer)
[2021-10-08 10:03:59,743] ERROR Exiting Kafka. (kafka.Kafka$)
[2021-10-08 10:03:59,752] INFO shutting down (kafka.server.KafkaServer)
 

Ответ №1:

Для того, чтобы начать кафку

  1. начните смотрителя зоопарка
  2. запустите сервер kafka

Сервер Кафки зависит от zookeeper. Для того, чтобы изучить поток, перейдите на указанный ниже сайт, https://www.javainuse.com/misc/apache-kafka-hello-world

Комментарии:

1. я попробую это сделать, спасибо

2. я пробую агин и агин, но та же проблема

3. [2021-10-13 13:56:00,400] ИНФОРМАЦИЯ [сервер ZooKeeperClient Kafka] Ждет подключения. (кафка.хранитель зоопарка.ZooKeeperClient)

4. [2021-10-13 13:56:00,413] ИНФОРМАЦИЯ об открытии подключения сокета к локальному хосту сервера/0:0:0:0:0:0:0:1:2181. (org.apache.смотритель зоопарка. ClientCnxn) [2021-10-13 13:56:00,414] ИНФОРМАЦИЯ Статус конфигурации SASL: Не будет предпринята попытка аутентификации с помощью SASL (неизвестная ошибка) (org.apache.zookeeper. ClientCnxn) [2021-10-13 13:56:02,461] ПРЕДУПРЕДИТЕ сеанс 0x0 для локального хоста sever/0:0:0:0:0:0:0:1:2181, Закрытие соединения с розеткой. Попытка повторного подключения, за исключением исключения SessionExpiredException. (org.apache.смотритель зоопарка. ClientCnxn) java.net.ConnectException: Отказано в подключении: дополнительной информации нет

5. «ОШИБКА Фатальная ошибка при запуске KafkaServer. Подготовьтесь к завершению работы (кафка.сервер. КафкаСервер)’