pyflink连接器支持问题

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

pyflink连接器支持问题

whh_960101
您好,请问pyflink现在支持的连接器有IBM MQ吗,因为需要使用到,感谢解答!
Reply | Threaded
Open this post in threaded view
|

Re: pyflink连接器支持问题

Xingbo Huang
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 <[hidden email]> 于2020年9月17日周四 下午2:46写道:

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