You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by whh_960101 <wh...@163.com> on 2020/09/17 06:46:00 UTC

pyflink连接器支持问题

您好，请问pyflink现在支持的连接器有IBM MQ吗，因为需要使用到，感谢解答！

Re: pyflink连接器支持问题

Posted by Xingbo Huang <hx...@gmail.com>.

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 <wh...@163.com> 于2020年9月17日周四 下午2:46写道：

> 您好，请问pyflink现在支持的连接器有IBM MQ吗，因为需要使用到，感谢解答！