THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!

Page History

Versions Compared

Key

This line was added.
This line was removed.
Formatting was changed.

...

https://issues.apache.org/jira/browse/KAFKA-4125 (Rich Functions)
https://issues.apache.org/jira/browse/KAFKA-3455 (valid?)
https://issues.apache.org/jira/browse/KAFKA-4713 (ProcessorContext.init)
https://issues.apache.org/jira/browse/KAFKA-4218 (add key to ValueTransformer – ie. mapValues and transformValues)
https://issues.apache.org/jira/browse/KAFKA-4217 (add flatTransform() and flatTransformValues() – seem invalid to me)
https://issues.apache.org/jira/browse/KAFKA-4346 (add foreachValue to KStream)
https://issues.apache.org/jira/browse/KAFKA-3745 (add key to ValueJoiner)
https://issues.apache.org/jira/browse/KAFKA-4726 (add key to ValueMapper)
https://issues.apache.org/jira/browse/KAFKA-4713 (Processors cannot call public methods on ProcessorContext from the init method)

Thus, to tackle this issue, it seems to be a good idea to break it down into groups of issues, and do a KIP per group to get a overall sound design.

...