Приветствую. Пускаю 3 KRaft брокера на localhost. config/kraft/server0.properties: node.id=1 controller.quorum.voters=1@localhost:9093,2@localhost:9095,3@localhost:9097 listeners=PLAINTEXT://:9092,CONTROLLER://:9093 advertised.listeners=PLAINTEXT://localhost:9092 config/kraft/server1.properties: node.id=2 controller.quorum.voters=1@localhost:9093,2@localhost:9095,3@localhost:9097 listeners=PLAINTEXT://:9094,CONTROLLER://:9095 advertised.listeners=PLAINTEXT://localhost:9094 config/kraft/server2.properties: node.id=3 controller.quorum.voters=1@localhost:9093,2@localhost:9095,3@localhost:9097 listeners=PLAINTEXT://:9096,CONTROLLER://:9097 advertised.listeners=PLAINTEXT://localhost:9096 Получаю ошибки виду [2023-10-16 17:21:22,579] INFO

[MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
[2023-10-16 17:21:22,649] INFO [RaftManager id=1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient)
[2023-10-16 17:21:22,649] WARN [RaftManager id=1] Connection to node 2 (localhost/127.0.0.1:9095) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2023-10-16 17:21:22,679] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
[2023-10-16 17:21:22,755] WARN [RaftManager id=1] Graceful shutdown timed out after 5000ms (org.apache.kafka.raft.KafkaRaftClient)
[2023-10-16 17:21:22,758] ERROR [kafka-1-raft-io-thread]: Graceful shutdown of RaftClient failed (kafka.raft.KafkaRaftManager$RaftIoThread)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown completed

Как эти 3 брокера запустить?

5 ответов

54 просмотра

с initial.broker.registration.timeout.ms пробовали поиграть?

Chnbvcb- Автор вопроса
Сергей Голод
с initial.broker.registration.timeout.ms пробовали...

Нет, но мнре думается, тут дело не в таймауте, он не видит остальные брокеры.

а не проще ли поднять через компоуз эти же три брокера и не иметь проблем с localhost?

Chnbvcb- Автор вопроса
Chnbvcb
Пока изучаю Kafka по курсу, так что вот.

на всякий случай https://habr.com/ru/companies/otus/articles/670440/

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

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

Всем привет) Я попробовал турбо роутер октябрьский. Вроде доволен, но возникла проблемка) Бутстраповские модалки плодят .modal-backdrop элементы Если модалка открыта, должне...
Виталий
3
Так а кто может спарсить всех участников чата? Идишники
Magic
18
да пофиг на капчу зашел в чат и молчишь при этом ты нонейм? пошел вон
Magic
17
Как удалить health check в Consul? Казалось бы, это должно быть не сложно, но я не могу найти в документации ничего про это, только про добавление service с health check "в н...
Roman
2
Привет, кто может сделать юзербота с апи? Задачи: - создавать группы - создавать каналы - задавать для созданных каналов аватарку или эмоджи, имя группы - добавлять в группы...
Lencore
13
Хотя вроде админка показывает удаленные модели, да? @dblackCat
Виталий
2
Privet! Mozhet jesti ideji - nemogu sdelatj upload backup s filestore cerez WEB. Fail okolo 450mb, eto mozhet bitj prichinoi? Nemogu ponjatj..kak zagruzitj backup... Poluchaju...
Matiss 🤘 Black Oak IT 🌳 Batumi 🌴 Latvija
5
Нужно магазин с тильды на опен кат перенести Есть кто умеет? В лс
Magic
8
Всем доброго вечера! Хочу поделиться своим злоключением с человеком, который, как оказалось сюда тоже скидывал свое резюме. Жаль, что я вашу группу не нашел раньше… человек ки...
Роман Ахмедзянов
4
А кто знает в тейлоре до сих пор есть конфликты слагов или поправили уже?
Black Cat
5
Карта сайта