...
JIRA:
Jira | ||||||
---|---|---|---|---|---|---|
|
Initial Github Proposal: https://github.com/apache/kafka/pull/5801
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Recently .to() was overloaded with new method which accepts TopicNameExtractor object as parameter, it allows dynamically chose needed topic based on input message or other conditions on-fly.
Unfortunately both of these approaches - to(String) and to(TopicNameExtractor) has limitation - they allows only single topic to be chosen as output for the stream.
Public Interfaces
Briefly list any new interfaces that will be introduced as part of this proposal or any existing interfaces that will be removed or changed. The purpose of this section is to concisely call out the public contract that will come along with this feature.
...