To write to two different output streams, you can call collector.send() twice.
>> For what I understand now, MessageCollector.send can only be called once in process, because it relates to Acks, checkpoint and processing loop. These should be pretty orthogonal. If the docs are misleading, please let us know. We'll fix them On Mon, Jul 10, 2017 at 11:56 PM, 舒琦 <sh...@eefung.com> wrote: > 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 > > -- Jagadish V, Graduate Student, Department of Computer Science, Stanford University
