Repository navigation
[Feature Request]: Implement IBM MQ Sink Connector for Python SDK #30716
Description
What would you like to happen?
I am proposing the implementation of an IBM MQ sink connector within the Apache Beam Python SDK. This feature would enable Apache Beam users to easily send data to IBM MQ, which is a widely used and robust messaging middleware. The absence of this connector in the Python SDK limits the integration capabilities for users working with IBM MQ in their data processing pipelines.
Issue Priority
Priority: 3 (nice-to-have improvement)
Issue Components
- Component: Python SDK
- Component: Java SDK
- Component: Go SDK
- Component: Typescript SDK
- Component: IO connector
- Component: Beam YAML
- Component: Beam examples
- Component: Beam playground
- Component: Beam katas
- Component: Website
- Component: Spark Runner
- Component: Flink Runner
- Component: Samza Runner
- Component: Twister2 Runner
- Component: Hazelcast Jet Runner
- Component: Google Cloud Dataflow Runner
Reacted by Slim6one
Activity
Abacn commentedon Mar 22, 2024
Note that Beam Java SDK has a JmsIO that can be used to connect to IBM MQ. For Python it's possible to write a cross-language wrapper
liferoad commentedon Mar 24, 2024
Do we need to write one with the Python autowrapper?
github-actions commentedon Feb 13, 2026
This issue has been marked as stale due to 150 days of inactivity. It will be closed in 30 days if no further activity occurs. If you think that’s incorrect or this issue still needs to be addressed, please simply write any comment. If closed, you can reopen the issue at any time. Thank you for your contributions.
github-actions commentedon Mar 16, 2026
This issue has been closed due to lack of activity. If you think that is incorrect, you can reopen the issue at any time.
Abacn commentedon Jul 23, 2026
After #39437 JmsIO is supported in Python SDK. One should be able to use IBM MQ. However we need to setup test for it to confirm it works properly