Hi, We created KIP-92 to propose adding per partition lag metrics to KafkaConsumer.
The KIP wiki link is the following: https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer Comments are welcome. Thanks, Jiangjie (Becket) Qin
