Hi! Flink currently does not have an automatic way to achieve this. However you can use an external system to monitor on Kafka metrics [1] (for example currently consumed offsets) and trigger savepoints when certain conditions are met.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka//#monitoring ZhangJian He <shoot...@gmail.com> 于2021年11月14日周日 下午3:11写道： > Hello, I am new to flink. > I want to know if I can generate savepoint according to the consuming > message numbers(in Pulsar/Kafka) > > > Thanks for your help > ZhangJian He > >
