Thanks for the KIP, it's a useful improvement. Just one question, the KIP
states that it's about adding per partition metrics for metrics that
already exist. However, when I look at the code, it seems that
`records-lag-avg` doesn't exist?
this.recordsFetchLag = metrics.sensor("records-lag");
this.recordsFetchLag.add(metrics.metricName("records-lag-max",
this.metricGrpName, "The maximum lag in terms of number of records for any
partition in this window"), new Max());
Ismael
On Thu, Dec 15, 2016 at 5:32 PM, Becket Qin <becket....@gmail.com> wrote:
> Hi,
>
> I want to start a voting thread on KIP-92 which proposes to add per
> partition lag metrics to KafkaConsumer. The KIP wiki page is below:
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> 92+-+Add+per+partition+lag+metrics+to+KafkaConsumer
>
> Thanks,
>
> Jiangjie (Becket) Qin
>
