Skip to content

KAFKA-8396: Clean up Transformer API#11553

Closed
jeqo wants to merge 2 commits intoapache:trunkfrom
jeqo:new-transformer
Closed

KAFKA-8396: Clean up Transformer API#11553
jeqo wants to merge 2 commits intoapache:trunkfrom
jeqo:new-transformer

Conversation

@jeqo
Copy link
Contributor

@jeqo jeqo commented Nov 30, 2021

(Requires KIP)

Introduces a internal ValueProcessor and ValueProcessorContext to validate keys do not change between processing and forwarding values to child processors.

This validation only applies when processing, and not when adding punctuators to the topology.

Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@mjsax mjsax added the streams label Dec 28, 2022
@mjsax mjsax closed this Aug 23, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants