Конвейер flink не обрабатывает сообщения Кафки после переключения источника
#apache-kafka #apache-flink #apache-beam #apache-beam-io Вопрос: У меня есть вариант использования для создания приложения с отслеживанием состояния. Мне нужно построить состояние с историческими данными, хранящимися в S3, и переключиться на кафку…