watermark kafka案例

时间:2022-03-28 05:16:00
【文件属性】:

文件名称:watermark kafka案例

文件大小:10KB

文件格式:ZIP

更新时间:2022-03-28 05:16:00

waterm kafka 案例 flink

kafka的多分区watermark机制,这个是在工作中使用的kafka的watermark机制,调试代码,感兴趣可以一观。


【文件预览】:
kafka
----KafkaWithoutWaterMark.java(4KB)
----KeyedSerializationSchemaWrapper.java(1KB)
----KafkaEvent.java(2KB)
----Util.java(461B)
----KafkaWithWaterMark.java(5KB)
----KafkaEventSchema.java(2KB)

网友评论