Итак, я пытаюсь включить семантику EXACTLY_ONCE в моем потоковом задании Flink Kafka вместе с контрольными точками. Однако я не могу заставить его работать, поэтому я попытался загрузить тестовый образец кода с Github:...

Я знал, что Apache Flink имеет емкость «Ровно один раз», которая полагается на механизм контрольной точки и источник данных, подлежащих повторной отправке. Насколько я понимаю, если оператор Flink получает некоторую ошибку, ему необходимо снова...

Apache Flink гарантирует однократную обработку после сбоя и восстановление путем возобновления задания с контрольной точки, при этом контрольная точка представляет собой согласованный моментальный снимок распределенного потока данных и состояния...

У нас есть установка Flink с производителем Kafka, который в настоящее время использует семантику хотя бы один раз . Мы рассматриваем возможность перехода на семантику ровно один раз в отношении производителя Kafka, поскольку это принесет нам...