You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "dajac (via GitHub)" <gi...@apache.org> on 2023/06/12 13:27:29 UTC

[GitHub] [kafka] dajac commented on pull request #13843: KAFKA-15080; Fetcher's lag never set when partition is idle

dajac commented on PR #13843:
URL: https://github.com/apache/kafka/pull/13843#issuecomment-1587345203

   This is exactly why I check `currentFetchState.lag.isEmpty` to ensure that it gets initialised in all cases on the first fetch. I would not include lag in InitialState because this is also what we use when a partition is added by the replica manager and the lag does not have any sense in this context. In the case you mentioned, the lag will be set on the first fetch.


-- 
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: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org