Кафка Флинк с использованием Python

Question

Я не вижу много информации о соединителе kafka flink python API. Я узнал, что он находится в бета-версии. Могу ли я использовать API соединителя kafkaflink, используя python. Если да, предложите мне программу для этого соединителя. Я также ссылался на Apache Flink: соединитель Kafka в Python потоковом API, «Не удается загрузить класс пользователя» . Также можно использовать концепцию скользящего окна с использованием python API.

Answer 1

Если вы придерживаетесь Table API, в Flink 1.9 есть некоторая поддержка Python, а в версии 1.10 скоро появится еще больше.

Sliding windows отлично работает с Kafka и Python через Table API в Flink 1.9. См. здесь для скольжения windows, а Кафку см. здесь .