...
ключ RiS_KRIffedSfMurdVxTDKw должен быть один и тот же для всех нод
Запуск сервиса
Пример файла сервиса kafka.service
[Unit]
Requires=network.target remote-fs.target
After=network.target remote-fs.target
[Service]
Type=simple
User=student
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
В конфигурационном файле wnam
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, то все задачи выполняются на этом сервере,
useCache: default true #optional, default 'defaulttrue'. Использовать локальный кэш. Может быть default, true или false, отключать кэш следует только в конфигурации когда нет кафки и больше одного сервера wnam
spring:
# применяется если kafka_enabled = true
kafka:
bootstrap-servers: 172.16.135.10:9092,10.241.200.123:9092,10.241.200.124:9092