Я не смог найти работающего примера использования соединителя Kafka вместе с Apache Flink Python API.
Может ли кто-нибудь привести рабочий пример?