git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Acknowledging Pubsub messages in Flink Runner


Hi Encho,

Flink does not provide Pubsub connector. I believe you are using Beam's
coder for PubsubIO. If this is correct, I guess you might want to ask
this question on Beam's mailing list.

Regards,

Dawid


On 10/09/18 17:24, Encho Mishinev wrote:
> Hello,
>
> I have a simple question - when does the Flink Runner for Apache Beam
> acknowledge Pubsub messages when using PubsubIO?
>
> Thanks


Attachment: signature.asc
Description: OpenPGP digital signature