Как управлять задержкой загрузки темы Kafka в таблицу с помощью API таблицы в pyflink ⇐ Python
-
Гость
Как управлять задержкой загрузки темы Kafka в таблицу с помощью API таблицы в pyflink
Я загружаю данные из двух тем Kafka в таблицы, используя table API в pyflink, и собираюсь выполнить операцию соединения. Что произойдет, если данные из одной из тем Kafka загрузятся в соответствующую таблицу с задержкой? если произойдет задержка, как мне справиться?
Итак, мы попробовали Windows, и он не работает должным образом, поэтому возникает проблема в том, что нам нужно сначала обнаружить задержку, возникающую при загрузке данных из темы Kafka в таблицу, а затем, если задержка произойдет, то как мы можем справиться с этой задержкой в таблице API pyflink.
как найти задержку и управлять ею?
Я загружаю данные из двух тем Kafka в таблицы, используя table API в pyflink, и собираюсь выполнить операцию соединения. Что произойдет, если данные из одной из тем Kafka загрузятся в соответствующую таблицу с задержкой? если произойдет задержка, как мне справиться?
Итак, мы попробовали Windows, и он не работает должным образом, поэтому возникает проблема в том, что нам нужно сначала обнаружить задержку, возникающую при загрузке данных из темы Kafka в таблицу, а затем, если задержка произойдет, то как мы можем справиться с этой задержкой в таблице API pyflink.
как найти задержку и управлять ею?
