Hi Mans,

Flink does not coordinate the consumption at all (neither within the same
nor across applications). Each FlinkKinesisConsumer will keep track of its
consumption (position in each shared) in order to provide exactly-once
guarantees.

Cheers,

Konstantin


On Mon, Jul 1, 2019 at 12:30 PM M Singh <mans2si...@yahoo.com> wrote:

> Hi:
>
> I am trying to understand how does Flink coordinate multiple kinesis
> consumers and am trying to find out:
>
> 1. Is it possible to read same kinesis stream independently multiple times
> within a single application ? How does Flink coordinate consuming same
> kinesis multiple times in a single application ? Are there any issues that
> can arise from this pattern ?
> 2. How does Flink coordinate consumers of same kinesis stream across
> multiple applications ?
>
> Thanks
>
> Mans
>


-- 

Konstantin Knauf | Solutions Architect

+49 160 91394525


Planned Absences: 10.08.2019 - 31.08.2019, 05.09. - 06.09.2010


--

Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany

--

Ververica GmbH
Registered at Amtsgericht Charlottenburg: HRB 158244 B
Managing Directors: Dr. Kostas Tzoumas, Dr. Stephan Ewen

Reply via email to