Luke Cwik created BEAM-5798:
-------------------------------

             Summary: 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


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to