Согласно документам здесь:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/
а также
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/
Можно ли создать собственный ddl-коннектор RabbitMQ для использования в pyflink TABLE API 1.11?
как?