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



zjfpla...@hotmail.com

回复