Dong Lin created KAFKA-4429:
-------------------------------
Summary: records-lag should be zero if FetchResponse is empty
Key: KAFKA-4429
URL: https://issues.apache.org/jira/browse/KAFKA-4429
Project: Kafka
Issue Type: Improvement
Reporter: Dong Lin
Assignee: Dong Lin
In Fetcher we record records-lag in terms of number of records for any
partition. Currently this metric value is updated only if number of parsed
records is not empty. This means that if consumer has already fully caught up
and there is no new data into the topic, this metric's value will be negative
infinity and users can not rely on this metric to know if their consumer has
caught up.
We can fix this problem by assuming the lag is zero is FetchResponse is empty.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
