Re: 对于kafka partition 设置时间戳及watermark

Sun, 20 Dec 2020 07:15:33 -0800 

setAutoWatermarkInterval这个只是设置interval。决定你那个抽取ts的函数的执行频率的。

r pp <[email protected]> 于2020年12月20日周日 上午10:49写道：

> 是的
>
> 张锴 <[email protected]> 于2020年12月19日周六 下午5:45写道：
>
> > 我按官网操作，重写了序列化方式
> >
> > val kafkaSource = new FlinkKafkaConsumer09[MyType]("myTopic", schema,
> > props)kafkaSource.assignTimestampsAndWatermarks(new
> > AscendingTimestampExtractor[MyType] {
> >     def extractAscendingTimestamp(element: MyType): Long =
> > element.eventTimestamp})
> > val stream: DataStream[MyType] = env.addSource(kafkaSource)
> >
> > *有个疑问，这样写完之后是不是不用设置*setAutoWatermarkInterval 呢？
> >
>

回复