Hi guys,

        How to write one message to two different output stream, let’s  say two 
different kafka cluster?
        
        For what I understand now, MessageCollector.send can only be called 
once in process, because it relates to Acks, checkpoint and processing loop.

        Thanks for you help!

————————
Qi Shu

Reply via email to