Добрый день. Подскажите, пожалуйста, как получить текущее значение конфигурационной переменной для брокера, когда он запущен?

Скажите, а есть ли кто в Кассандре разбирается? Может у кассандры свой телеграм канал есть (не могу найти)

Могу неспешно ответить на многие вопросы. Можно в личку.

Спасибо, написал в личку

Если есть доступ к логам, то при старте в server.log по-умолчанию выводится конфиг

логам:  имеются ввиду те, что написаны в /log/dirs?

Которые по-умолчанию /kafka_{version}/logs

Понял, спасибо.

А про какую переменную речь? Еще есть набор консольных утилит (kafka-configs, kafka-topics, kafka-consumer-groups), через которые тоже можно узнать текущие конфиги

Речь идёт о переменных auto.create.topics.enable и allow.auto.create.topics

kafka-configs.sh --bootstrap-server 192.168.60.30:9092 --entity-type brokers --entity-name 1 --describe --all | grep auto.create.topics.enable

Спасибо большое!

Переменные --entity-* не учёл

да, по идее это только настройки брокера, там ещё можно настройки топиков и тд глянуть. Но вроде как раз дефолтные настройки они с настроек брокера берутся, поэтому должны там быть

+1

Кстати, если auto.create.topics.enable=true стоит, а по allow.auto.create.topics  ничего не высвечивается, то это означает, что топики могут автоматически создаваться?

В документации для этого параметра дефолтное значение — True.

Коллеги, нужен совет. есть 3х нодовый кафка кластер. одна нода зукипер с id=1 (некоторое время назад и данные на нем уже не актуальные) выпал из ансамбля и теперь при попытках вернуть его обратно, я получаю сообщение: [QuorumConnectionThread-[myid=1]-2:QuorumCnxManager@513] - Have smaller server identifier, so dropping the connection: (myId:1 --> sid:3). Лид сейчас 3-я нода. Поделитесь опытом как его можно вернуть обратно, на навернув весь стек?

Всем привет.
Кто-нибудь сталкивался с проблемой write tcp 10.244.3.228:50748->10.135.229.23:9092: write: broken pipe в golang клиете sarama v1.27.2 (kafka v2.3.0) с использованием SyncProducer?

Заранее большое спасибо за ответ

Подобная петрушка была, когда были проблемы с дисками и зукипер часто разваливал ансамбль.
Единственное решение которое я нашел, посмотреть версию Zxid на всех ZK нодах и ребутнуть зукипер на той, где не сходится этот Zxid