chia7712 commented on PR #23431: URL: https://github.com/apache/kafka/pull/23431#issuecomment-5755167076
> The main reason the consumer fetch lag was not implemented in the past was that the consumer didn't provide enough information, and fetching partition end offsets on every poll was too expensive. However, since [KIP-695](https://cwiki.apache.org/confluence/x/JSXZCQ?utm_source=gemini), the currentLag method is available, which allows us to query the current consumer lag directly from the local cache. I believe we can now implement this metric using this approach. No one has complained about it, so I'm not convinced of the value of this metric. Also, the consumer metrics already include the lag-related metrics, so it looks like a duplicate. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
