Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

В консоли на каждом сервере инициализировать кафку
Сначала генерим ключ, например RiS_KRIffedSfMurdVxTDKw
Можно командой bin/kafka-storage.sh random-uuid
потом в консоли на каждом сервере выполняем команду
./bin/kafka-storage.sh format -t RiS_KRIffedSfMurdVxTDKw -c config/kraft/server.properties

ключ RiS_KRIffedSfMurdVxTDKw должен быть один и тот же для всех нод

в параметре

controller.quorum.voters=1@172.16.135.10:9093,2@10.241.200.123:9093,3@10.241.200.124:9093

числа перед @ это node.id, они должны быть прописаны одинаково в конфигурациях на всех нодах



Запуск сервиса

Пример файла сервиса kafka.service

[Unit]
Requires=network.target remote-fs.target
After=network.target remote-fs.target

[Service]
Type=simple
User=wnam
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/kraft/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
TimeoutSec=30
Restart=always
RestartSec=20s

[Install]
WantedBy=multi-user.target


В конфигурационном файле /home/wnam/application.yaml :

...