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-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
