vvcephei opened a new pull request #11336: URL: https://github.com/apache/kafka/pull/11336
Similar to the currentStreamTime/currentSystemTime methods in KIP-622, this PR demonstrates adding a currentPositions call to the ProcessorContext, which returns the task's current offset position in each of its input topic partitions. This is a fairly advanced requirement, which most applications would never need, but if an application does need to know the current position, there is no other way they could compute it. If the initial reception to this POC is positive, I'll follow up with a KIP. ### 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
