Запустите потоковое приложение flink с определенного смещения разделов кафки в теме

#kafka-consumer-api #flink-streaming Вопрос: Мое приложение Flink указывает на тему кафки с 5 разделами. Каждый раздел содержит данные, полученные в качестве события CDC из исходной базы данных, размещенной для клиента. DB1->…

Продолжить чтениеЗапустите потоковое приложение flink с определенного смещения разделов кафки в теме