gt; On Wed, Sep 22, 2021 at 5:37 PM Robert Cullen
> wrote:
>
>> I have an unbounded kafka source that has records written to it every
>> second. Instead of the job waiting to process the new messages it closes.
>> How do I keep the stream open?
>>
>> KafkaSource dat
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
flink/flink-docs-master/docs/connectors/datastream/kafka/#boundedness
On Wed, Sep 22, 2021 at 5:37 PM Robert Cullen wrote:
> I have an unbounded kafka source that has records written to it every
> second. Instead of the job waiting to process the new messages it closes.
> How do I keep
I have an unbounded kafka source that has records written to it every
second. Instead of the job waiting to process the new messages it closes.
How do I keep the stream open?
KafkaSource dataSource = KafkaSource
.builder()
.setBootstrapServers(kafkaServer)
.setTopics
