cadonna opened a new pull request #10360: URL: https://github.com/apache/kafka/pull/10360
Emit on change introduced in Streams with KIP-557 might lead to data loss if a record is put into a source KTable and emitted downstream and then a failure happens before the offset could be committed. After Streams rereads the record, it would find a record with the same key, value and timestamp in the KTable (i.e. the same record that was put into the KTable before the failure) and not forward it downstreams. Hence, the record would never be processed downstream of the KTable which breaks at-least-once and exactly-once processing guarantees. ### 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
