kafka
kafka copied to clipboard
KAFKA-7663: initial commit for reprocessing on user added stores
When custom processors are added via StreamBuilder#addGlobalStore they will now reprocess all records through the custom transformer instead of loading directly.
We do this so that users that transform the records will not get improperly formatted records down stream.
Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
I might need to add a couple of unit tests, but I think it could use a review when you got time @mjsax !
@mjsax I added some testing that you asked for
Jenkins needs a re-run...
Test configuration issues in the build is in `core:test' and not related to this PR