Даже если вы не используете явно состояние в вашем приложении, соединители источника и приемника Flink Kafka используют состояние от вашего имени, чтобы предоставить вам гарантии, по крайней мере, один раз или точно один раз, при условии, что вы заботитесь о эти гарантии. Кроме того, некоторые другие операторы также будут использовать состояние несколько прозрачно от вашего имени, например окна и другие потоковые агрегаты.
Если ваше задание Flink не выполнено, оно будет перемотано обратно к последней успешной контрольной точке и возобновит обработку с этого момента. Так, например, если интервал между контрольными точками составляет 10 минут, то после восстановления у вашей работы может быть более 10 минут данных, чтобы наверстать упущенное, прежде чем она сможет возобновить обработку живых данных. Поэтому выберите интервал контрольных точек, с которым вы можете жить с этой точки зрения.