Согласно документам здесь:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/
и
можно ли создать собственный ddl-коннектор RabbitMQ для использования в pyflink TABLE API 1.11?
как?
Во-первых, вам необходимо реализовать собственную реализацию коннектора на основе интерфейса, предоставляемого Java. Затем вам нужно использовать параметры API или командной строки для ссылки на используемую банку, на которую вы можете ссылаться https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/common_questions.html#adding -jar-files