Конец, чтобы закончить точно один раз пример кода

Question

Я новичок в потоковой передаче Apache Flink и хочу реализовать конец-конец ровно один раз.Я прочитал следующий блог и получил основные идеи (я знаю, как это работает): https://flink.apache.org/features/2018/03/01/end-to-end-exactly-once-apache-flink.html

Но я не смог найти ни одного примера (пример исходного кода).Есть ли исходный код реализации сквозной точно-один раз с использованием twoPhaseCommitSinkFunction -thanks

Answer 1

FlinkKafkaProducer011 реализует TwoPhaseCommitSinkFunction и может быть найден здесь .