dajac commented on code in PR #15155:
URL: https://github.com/apache/kafka/pull/15155#discussion_r1447230142
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##########
@@ -668,6 +697,8 @@ public OffsetFetchResponseData.OffsetFetchResponseGroup
fetchOffsets(
OffsetFetchRequestData.OffsetFetchRequestGroup request,
long lastCommittedOffset
) throws ApiException {
+ final boolean requireStable = lastCommittedOffset == Long.MAX_VALUE;
Review Comment:
Correct. When the require stable flag is set in the offset fetch request,
the read operation reads with `MAX_VALUE` in order to read the latest state. If
the flag is not set, the read op reads with the last committed offset.
--
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
