Kafka в составе cp-all-in-one падает с ошибкой ERROR [KafkaServer id=1]

Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.IllegalStateException: Kafka HTTP server failed to start up.
at kafka.server.KafkaServer.startup(KafkaServer.scala:603)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
at kafka.Kafka$.main(Kafka.scala:82)
at kafka.Kafka.main(Kafka.scala).
Что бы это могло значить? Вчера все работало.

7 ответов

29 просмотров

Порт нужный занят?

Anton- Автор вопроса
Sergey Bezrukov
Порт нужный занят?

проверил - все свободны

Мало информации

Anton- Автор вопроса
Vik Gamov
Мало информации

Я знаю. Но в логах больше ничего подозрительного нет. Unknown host exception: broker идет уже после того как кафка упала.

Anton- Автор вопроса
Vik Gamov
А Кафка почему упала?

В логе кафки единственная ошибка - ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) java.lang.IllegalStateException: Kafka HTTP server failed to start up. at kafka.server.KafkaServer.startup(KafkaServer.scala:603) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44) at kafka.Kafka$.main(Kafka.scala:82) at kafka.Kafka.main(Kafka.scala).

Anton- Автор вопроса
Vik Gamov
А Кафка почему упала?

После перезапуска вот еще что попалось: ERROR Error while creating ephemeral at /brokers/ids/1, node already exists and owner '72067588561567745' does not match current session '72057599798345729' (kafka.zk.KafkaZkClient$CheckedEphemeral) ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists at org.apache.zookeeper.KeeperException.create(KeeperException.java:126) at kafka.zk.KafkaZkClient$CheckedEphemeral.getAfterNodeExists(KafkaZkClient.scala:2057) at kafka.zk.KafkaZkClient$CheckedEphemeral.create(KafkaZkClient.scala:1995) at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1962) at kafka.zk.KafkaZkClient.registerBroker(KafkaZkClient.scala:98) at kafka.server.KafkaServer.startup(KafkaServer.scala:470) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44) at kafka.Kafka$.main(Kafka.scala:82) at kafka.Kafka.main(Kafka.scala)

Похожие вопросы

Обсуждают сегодня

Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
всем привет помогите пожалуйста используя CDN (GCP) у игроков из вьетнама загружается конфиг (размер 999 bytes) загружается 5 и более минут н а других CDN сервисах такой пробл...
Andrew Krw.
1
Добрый день. Мне посоветовали обратиться к вам в чат за помощью. Ситуация описана на скрине. Как мне сказали, мне на бота навесили флудвейт. Есть ли возможность снять его ра...
OVERLINK
7
Просто по очереди выпиливаешь на ручной маппинг? По методу за раз
Andrii Kurdiumov
7
)) может, нужно поправить? )) 2. Ребята, нам нужно, чтобы сообщения из Инстаграм приходили в ОДУ. Какое приложение посоветуете?
Alexander Sharoiko MSE / Александр Шаройко
1
Я правильно понимаю что нет способов получить список ожидающих заявок на вступление в группу с помощью бота из mtproto?
Шамиль Прилов
7
Приветствую. А не подскажете какие ограничения есть на использования api метода setMyName ? Несколько раз сменил имя бота и получил бан на 2 месяца на смену имени.
Slick Slack
8
И? Все равно глазами проверять надо каждое поле
Andrii Kurdiumov
4
Всем привет! Взялся портировать модули на 18 версию, лезет _logger.log(log_level, 'no translation language detected, skipping translation %s', frame, stack_info=True) А чт...
Max Lit
3
Ну есть у нас десяток компаний которым надо. Остальным то зачем?
Andrii Kurdiumov
4
Карта сайта