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
