Hi Jagadish,
When write one message to two different output streams, Samza will wait
acks from two different streams and then process checkpointing. Do I understand
right?
Thanks for your help!
————————
QiShu
> 在 2017年7月12日，03:48，Jagadish Venkatraman <jagadish1...@gmail.com> 写道：
>
> 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
