kafka的多分区watermark

Sun, 13 Dec 2020 21:51:30 -0800 

在官网看到对于Kafka分区的时间戳定义描述，给出了示例，如下图：

FlinkKafkaConsumer09<MyType> kafkaSource = new
FlinkKafkaConsumer09<>("myTopic", schema,
props);kafkaSource.assignTimestampsAndWatermarks(new
AscendingTimestampExtractor<MyType>() {

    @Override
    public long extractAscendingTimestamp(MyType element) {
        return element.eventTimestamp();
    }});
DataStream<MyType> stream = env.addSource(kafkaSource);

*不太理解这个里面泛型传的是用户定义的case class，还是传*ConsumerRecord,从他里面提取时间戳

回复