Flink整合kafka并基于事件源生成时间戳以及水印

本案例仅为官方文档案例补全说明。html Flink整合Kafka，为Kafka中消息指定时间戳以及生成水印。java 消息格式：id，消息生成时间戳，消息体apache 定义消息类：api public class MyEvent implements Serializable { private String id; private Long eventTime; pr

>>阅读原文<<