Как управлять задержкой загрузки темы Kafka в таблицу с помощью API таблицы в pyflink ⇐ Python

[Гость]

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

Итак, мы попробовали Windows, и он не работает должным образом, поэтому возникает проблема в том, что нам нужно сначала обнаружить задержку, возникающую при загрузке данных из темы Kafka в таблицу, а затем, если задержка произойдет, то как мы можем справиться с этой задержкой в ​​таблице API pyflink.

как найти задержку и управлять ею?