Description
While transforming values via KStream.transformValues and ValueTransformer, the key associated with the value may be needed, even if it is not changed. For instance, it may be used to access stores.
As of now, the key is not available within these methods and interfaces, leading to the use of KStream.transform and Transformer, and the unnecessary creation of new KeyValue objects.
Attachments
Issue Links
- contains
-
KAFKA-4726 ValueMapper should have (read) access to key
- Resolved
-
KAFKA-3745 Consider adding join key to ValueJoiner interface
- Resolved
- is related to
-
KAFKA-7842 Reducer should have (read) access to key
- Open
-
KAFKA-7843 Initializer should have (read) access to key
- Open
- links to