CODEWITHSUNDEEP
apache-flink
bbaja42
bbaja42

Reputation: 2169

What is default flink watermark strategy for kafka source connector?

From this documentation I can read following:

By default, the record will use the timestamp embedded in Kafka ConsumerRecord as the event time. You can define your own WatermarkStrategy for extract event time from the record itself, and emit watermark downstream:

env.fromSource(kafkaSource, new CustomWatermarkStrategy(), "Kafka Source With Custom Watermark Strategy")

This documentation describes details about how to define a WatermarkStrategy.

What Watermark strategy is used if user doesn't provide the optional one?

I'm asking, because I found that default is empty in the source code.

We are running Flink 1.11.

Upvotes: 2

Views: 1820

Answers (1)

David Anderson
David Anderson

Reputation: 43499

There is no default watermark strategy. If you don't provide one there will be no watermarks.

Upvotes: 4

Related Questions