Hi, 现在flink没有提供官方的IBM MQ的connector实现,现在已经支持的connector类型,你可以参考文档[1]。如果你需要支持其他connector,你需要提供自定义的connector的java实现,然后在你的python作业里面通过api或者命令行参数的方式把connector的Jar包添加进去,具体可以参考文档[2]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/ [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/python/faq.html#adding-jar-files Best, Xingbo whh_960101 <whh_960...@163.com> 于2020年9月17日周四 下午2:46写道: > 您好,请问pyflink现在支持的连接器有IBM MQ吗,因为需要使用到,感谢解答!