Versions Compared

Key

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

...

JIRA:

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7578
 

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.

...