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)

网友评论