Обработка или отслеживание выдающихся сообщений Кафки

#apache-flink #flink-streaming Вопрос: Когда мы перезапускаем задание Flink, оно должно обработать миллионы невыполненных сообщений из нескольких тем Кафки, которые накопились, когда задание Flink не выполнялось. Внезапно, как только задание начнется,…