kafka 源连接器的默认 flink 水印策略是什么？
What is default flink watermark strategy for kafka source connector?
来自 this documentation 我可以阅读以下内容：
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.
如果用户不提供可选的水印策略，使用什么水印策略？
我在问，因为我发现默认是空的in the source code。
我们是 运行 Flink 1.11.
没有默认的水印策略。如果您不提供，则没有水印。
来自 this documentation 我可以阅读以下内容：
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.
如果用户不提供可选的水印策略，使用什么水印策略？
我在问，因为我发现默认是空的in the source code。
我们是 运行 Flink 1.11.
没有默认的水印策略。如果您不提供，则没有水印。