У меня есть источник kafka, из которого мое приложение flink считывает данные и обрабатывает их, я хочу добавить механизм точки сохранения flink, чтобы возобновить процесс с последнего места, где он был оставлен. Вместо добавления точки сохранения в источник kafka я хочу, чтобы мое приложение поддерживало состояние последнего обработанного потока, чтобы он не повторно обрабатывал мои данные, которые частично обрабатываются моим приложением.
Я добавил точку сохранения в источник kafka, который возобновляет поток kafka, но вместо этого я хочу возобновить поток обработанных данных
DataStream<String> streamOfStrings = env.addSource(new FlinkKafkaConsumer010<>(topicname));
Мой строковый поток далее передается другому процессу, который преобразуется в поток данных объекта. Я хочу, чтобы состояние обрабатываемого потока сохранялось, но не поток кафка. Есть ли способ прикрепить точку сохранения к потоку данных
DataStream<Object> streamOfObject = App.convertToObject(streamOfStrings);
