Не получает значения для records-lag-max для метрики jmx потребителя kafka

Question

Я запускаю потоковое приложение java kafka с включенным JMX.Я пытаюсь получить потребительские лаги, но получаю бесконечность для всех потребителей, которые есть у приложения.

Я смотрю следующие jmx метрики:

kafka.consumer.type_consumer-fetch-manager-metrics.client-id_consumer-v1*.records-lag-max

Яне уверен, почему это не дает точного значения.Пожалуйста, дайте мне знать:

• Если я что-то здесь упустил,
• ИЛИ, ища неправильные метрики,
• ИЛИ Нужно выполнить дополнительную настройку, чтобы получитьпотребительские лаги.

Заранее спасибо !!!

Answer 1

Я получил причину проблемы.На самом деле, в случае потребительских лагов моя служба пыталась бесконечно долго подключаться к базе данных, которая мешала потребителям генерировать метрики, поэтому я получал значение как бесконечное.

Итак, ничего не былоНеправильно со стороны JMX, это был случай использования, который вызывал проблему.