flink offset自定义存储

Mon, 18 Jan 2021 23:39:13 -0800 

Hi,
        flink有没有方式自定义偏移量存储，例如存redis等，不使用checkpoint/savepoint等，类似spark 
streaming的功能：
https://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html#your-own-data-store
 
       



[email protected]

回复