根据这里的文档：
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/
是否可以创建用于 pyflink TABLE API 1.11 的自定义 ddl RabbitMQ 连接器？
如何？
问问题
217 次
1 回答
0
首先，您需要基于 Java 提供的接口来实现您的自定义连接器实现。然后需要使用API或者命令行参数来引用使用的jar，可以参考 https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/ common_questions.html#adding-jar-files
于 2020-07-10T03:24:17.073 回答