Description
KStream.transform gives you access to state stores while allowing you to return zero or one transformed KeyValue. Alas, it is unclear what method you should use if you want to access state stores and return zero or multiple KeyValue. Presumably you can use transform, always return null, and use ProcessorContext.forward to emit KeyValues.
It may be good to introduce a transform-like flatMap equivalent, or allow store access from other KStream methods, such as flatMap itself.
Attachments
Issue Links
- is duplicated by
-
KAFKA-3543 Allow a variant of transform() which can emit multiple values
-
- Resolved
-
- is related to
-
-
- Resolved
-
- relates to
-
-
- Open
-
- links to