Versions Compared

Key

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

...

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

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

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

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

[Service]
Type=simple
User=studentwnam
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


netams:
  wnam:
    cluster:
      prefix: wnam-cluster- #optional, префикс для id сервера
      kafka_enabled: true #optional, default false. Использовать kafka
      main: true #optional default false
      replicas: 3 # optional,  default 1 количество реплик  (серверов) в кластере kafka
      unclean_election: true #optional, default true. Пытаться выбрать лидера в kafka при падении брокеров kafka
      role: master #optional,  default empty.Если master, то все задачи выполняются на этом сервере,

...