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
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