Я пытаюсь подтвердить, что конфиг Kafka Consumer работает правильно.Я устанавливаю некоторые значения свойств потребителя не по умолчанию (например, session.timeout.ms, heartbeat.interval.ms).Есть ли способ запросить их и убедиться, что для них заданы конкретные значения, которые я определяю в своих свойствах?
Я выполнил поиск в Интернете, но, похоже, не могу найти никакого руководства о том, как запросить контроллер группы для этих конфигураций.
Ближайший подход, который я нашел, - это использование kafka-consumer-groups.sh, но он не дает всех подробностей.
Есть идеи?
Спасибо за любые предложения!
Некоторые дополнительные пояснения, основанные на обратной связи: я использую ведение журнала, однако я не думаю, что это то, что я хочу проверить.
Позвольте мне попытаться уточнить немного дальше.Давайте возьмем session.timeout.ms в качестве примера.Этот параметр используется координатором группы, чтобы определить, жив ли конкретный потребитель.Поэтому я думаю, что координатор группы (который является брокером kafka) должен знать об этой настройке на стороне сервера.Поэтому, если для тайм-аута сеанса задано значение, отличное от значения по умолчанию, мне будет интересно, есть ли способ запросить посредника, чтобы получить этот параметр.Если я использую ведение журнала, я получу параметр конфигурации для объекта, который был создан при создании потребителя Kafka.Он не предоставляет мне ценности от брокера.Я надеюсь, что это проясняет вопрос.Пожалуйста, поправьте меня, если я понимаю, что это неправильно.