kafka的多分区watermark？

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

FlinkKafkaConsumer09 kafkaSource = new

FlinkKafkaConsumer09<>("myTopic", schema,

props);kafkaSource.assignTimestampsAndWatermarks(new

AscendingTimestampExtractor () {

@Override

public long extractAscendingTimestamp(MyType element) {

return element.eventTimestamp();

}});

DataStream stream = env.addSource(kafkaSource);

不太理解这个里面泛型传的是用户定义的case class，还是传ConsumerRecord,从他里面提取时间戳*来自志愿者整理的flink邮件归档