Источник и приемник пользовательской таблицы RabbitMQ для pyflink 1.11

Question

Согласно документам здесь:

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?

как?

Answer 1

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