kafka源连接器的默认闪烁水印策略是什么？
从本文档中，我可以阅读以下内容：
默认情况下，记录将使用Kafka ConsumerRecord中嵌入的时间戳作为事件时间。您可以定义自己的水印策略，从记录本身提取事件时间，并向下游发出水印：
env.fromSource(kafkaSource, new CustomWatermarkStrategy(), "Kafka Source With Custom Watermark Strategy")
本文档详细描述了如何定义水印策略。
如果用户不提供可选的水印策略，将使用什么水印策略？
我这样问是因为我发现源代码中的默认值是空的。
我们正在运行Flink 1.11。
共有1个答案
没有默认的水印策略。如果不提供水印，则不会有水印。
-
我正在阅读《Stream Processing with Apache Flink》一书，书中说：“从版本0.10.0开始，Kafka支持消息时间戳。当从Kafka版本0.10或更高版本读取时，如果应用程序以事件时间模式运行，使用者将自动提取消息时间戳作为事件时间戳*“因此在函数中，调用将默认返回Kafka消息时间戳？请提供一个简单的示例，说明如何实现AssignerWithPeriodicalW
-
我们正在构建一个流处理管道，以使用Flink v1.11和事件时间特性来处理Kinesis消息。在定义源水印策略时，在官方留档中，我遇到了两个开箱即用的水印策略；forBoundedOutOfOrthy和forMonotonousTimestamps。但根据我对上述内容的理解，我认为这些不适合我的用法。以下是我的用法细节： 来自输入流的数据：（包含每分钟带有时间戳的数据） 现在，我想处理11:00
-
默认情况下，身份认证并不需要访问资源。当安全约束（如果有）包含的url-pattern 是请求 URI 的最佳匹配，且结合了施加在请求的 HTTP 方法上的 auth-constraint（指定的角色），则身份认证是需要的。同样，一个受保护的传输是不需要的，除非应用到请求的安全约束结合了施加在请求的HTTP方法上的 user-data-constraint（有一个受保护的transport-gua
-
我们正在构建一个流处理管道来处理/摄取Kafka消息。我们正在使用Flink v1.12.2。在定义源水印策略时，在官方留档中，我遇到了两种开箱即用的水印策略；forBoundedOutOfOrness和forMonotonousTimestamps。我确实浏览了javadoc，但并不完全理解何时以及为什么你应该使用一种策略而不是另一种策略。时间戳基于事件时间。谢谢。
-
我在 AWS S3 中备份了以下文件，这些文件由 Kafka 连接接收器连接器备份： 当使用Kafka connect S3源恢复主题时，密钥文件被忽略，我在日志中看到以下调试消息: 我的源配置如下所示： 我应该做什么改变才能让密钥和消息一起存储在Kafka中？