Yes, it may be better to pull out the topic selection into an upstream
operator that emits the messages on separate ports per topic and then you
can use the exactly-once output operator without customization.
On Wed, Oct 12, 2016 at 11:29 AM, Bandaru, Srinivas <
srinivas.band...@optum.com>
Just a correction for use case.
Use case: kafka producer emits messages and processing messages using
Datatorrent application, Based on the DT application logic divide the messages
into two different groups and write it to two different kafka topics
Thanks,
Srinivas
From: Bandaru, Srinivas
