Flink整合kafka並基於事件源生成時間戳以及水印

本案例僅爲官方文檔案例補全說明。html Flink整合Kafka，爲Kafka中消息指定時間戳以及生成水印。java 消息格式：id，消息生成時間戳，消息體apache 定義消息類：api public class MyEvent implements Serializable { private String id; private Long eventTime; pr

>>阅读原文<<