Robert,
So removing the setUnbounded(OffsetInitializer.latest) fixed the issue.
Thanks!
On Wed, Sep 22, 2021 at 11:51 AM Robert Metzger wrote:
> Hi,
>
> What happens if you do not set any boundedness on the KafkaSource?
> For a DataStream job in streaming mode, the Kafka source should be
> unbo
mistaken …
Thias
From: Robert Metzger
Sent: Mittwoch, 22. September 2021 17:51
To: Robert Cullen
Cc: user
Subject: Re: Unbounded Kafka Source
Hi,
What happens if you do not set any boundedness on the KafkaSource?
For a DataStream job in streaming mode, the Kafka source should be unbounded.
From
Hi,
What happens if you do not set any boundedness on the KafkaSource?
For a DataStream job in streaming mode, the Kafka source should be
unbounded.
>From reading the code, it seems that setting unbounded(latest) should not
trigger the behavior you mention ... but the Flink docs are not clearly
w
