[ https://issues.apache.org/jira/browse/BEAM-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Luke Cwik updated BEAM-5798: ---------------------------- Description: Add support for writing to Kafka based upon contents of the data. This is similar to the dynamic destination approach for file IO and other sinks. Source of request: https://lists.apache.org/thread.html/a89d1d32ecdb50c42271e805cc01a651ee3623b4df97c39baf4f2053@%3Cuser.beam.apache.org%3E was:Add support for writing to Kafka based upon contents of the data. This is similar to the dynamic destination approach for file IO and other sinks. > Add support for dynamic destinations when writing to Kafka > ---------------------------------------------------------- > > Key: BEAM-5798 > URL: https://issues.apache.org/jira/browse/BEAM-5798 > Project: Beam > Issue Type: New Feature > Components: io-java-kafka > Reporter: Luke Cwik > Priority: Major > > Add support for writing to Kafka based upon contents of the data. This is > similar to the dynamic destination approach for file IO and other sinks. > > Source of request: > https://lists.apache.org/thread.html/a89d1d32ecdb50c42271e805cc01a651ee3623b4df97c39baf4f2053@%3Cuser.beam.apache.org%3E -- This message was sent by Atlassian JIRA (v7.6.3#76005)