New metrics - kafka lag per consumer

[SavkeSD]

Hi all,

Correct me if I am wrong, but currently we don't have metric to see which exact consumer is lagging per topic/partition. We have info for ConsumerGroup lag per topic/partition, but we cant exactly know which consumer is lagging, just which Consumer Group.
If there is metric for that, please point it up. But if not, will be good to consider to implement this feature.

That's something that can be achieved with ./kafka-consumer-groups.sh --bootstrap-server broker1:9092 --command-config admin.properties --describe --group someConsumerGroup, and output should look like:

GROUP | TOPIC |  PARTITION | CURRENT-OFFSET | LOG-END-OFFSET | LAG | CONSUMER-ID | HOST|   CLIENT-ID