我正在将来自 Kafka 流光的消息带到 Flink 中。该消息中包含Record_time字段，我想根据Record_time应用时间窗口。
是否可以提取或使用Record_time字段为该消息分配时间戳？由于接口TimestampExtractor的所有方法都被弃用，还有其他方法可以做到这一点吗？
TimestampExtractor已被弃用并替换为AssignerWithPeriodicWatermarks和AssignerWithPunctuatedWatermarks。
AssignerWithPeriodicWatermarks 提取每条记录的时间戳，并定期查询当前水印。
"AssignerWithPunctuatedWatermarks"也会提取每条记录的时间戳。此外，还要求每条记录提取水印。如果在特殊记录中对水印进行编码，这将非常有用。