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 CwikAdd 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)
