Как параметр kafka metrics.num.samples влияет на вычисление records-lag-max?

Question

При получении метрик потребителя через API потребителя kafka records-lag-max иногда возвращает 0, хотя описание группы потребителей с помощью инструмента kafka-consumer-groups.sh показывает, что потребитель отстает. Для metrics.sample.window.ms по умолчанию установлено значение 30 с, а для metrics.num.samples установлено значение 2 по умолчанию. Как metrics.num.samples влияет на этот расчет records-lag-max?

Answer 1

Я не думаю, что это имеет какое-либо влияние.

records-lag- * управляется полем с последним смещением структуры ответа выборки, которая сообщает клиенту, где находится "край" раздела намаклер. Затем клиент сравнивает это смещение с последним смещением, возвращенным в фактическом ответе на выборку, чтобы выяснить, сколько записей находится «позади» посредника.

эти метрики обновляются каждый раз, когда ответ выборки получен от посредника (ов). ), и если вы запросите их до того, как будут получены какие-либо такие ответы, вы можете увидеть 0.

с другой стороны, kafka-consumer-groups показывает вам, где не находится конкретный потребитель (последние смещения, доставленные этомупотребитель), но что смещает этот потребитель последний контрольный пункт к кафке. периодические смещения контрольных точек потребителей (обычно один раз каждые 30-60 секунд), и поэтому описание группы потребителей может показывать задержку, отличную от 0, где метрики самих потребителей (которые обновляются чаще) будут показывать 0.