Добавить метрку consumer lag

В librdkafka есть внутренняя статистика которую можно пробросить в prometeus.

В wiki есть статья как это можно сделать.