dajac opened a new pull request, #15221: URL: https://github.com/apache/kafka/pull/15221
This is the last patch to complete the implementation of the transactional offsets. This patch updates the following paths: * delete offsets - the patch ensures that a tombstone is written for pending transactional offsets too. * delete all offsets - the patch ensures that all pending transactional offsets are deleted too. * expire offsets - the patch ensures that an offset for a partition is not expire is there is a pending transaction. * replay offset record - the patch ensures that all pending transactional offsets are removed when a tombstone is received. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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
