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