ShivsundarR commented on PR #19295: URL: https://github.com/apache/kafka/pull/19295#issuecomment-2758130014
@AndrewJSchofield as @chia7712 mentioned if the case arises where successive `ShareFetchResponses` have only control records (eg. 2 abort markers received in read_commited mode), and if the second response came in at `fetchBuffer.awaitNotEmpty(pollTimer);`, then when we do `collect(Collections.emptyMap())`, then we would get a new set of acknowledgements for control records, but this time, these incoming acknowledgements would be ignored and missed. Here we might have to combine the acknowledgements. -- 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
