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)

Reply via email to