Is there a stable, ideally official JMS/ActiveMQ connector for Spark?

[amichel]

We're delivering pipelines that are mostly based on Databricks Spark Streaming, Delta Lake and Azure Event Hubs, and there's a requirement to integrate with AMQ/JMS endpoints (Request and Response queues in ActiveMQ).

Is there a proven way to integrate them as sources and sinks in Spark streaming jobs?

I could use Kafka Connect, Flink or custom code (CAML/Akka) to sync those queues to Event Hubs, but if a tested solution exists, customer prefers to avoid extra dependencies.

[Kaniz_Fatma]

Hi @ amichel! My name is Kaniz, and I'm the technical moderator here. Great to meet you, and thanks for your question! Let's see if your peers in the community have an answer to your question first. Or else I will follow up with my team and get back to you soon. Thanks.

[amichel]

Hi @Kaniz Fatma​ 

Any insights from your team? We're facing the delivery deadline and need to decide on the optimal solution.

Thank you,

Alex

[Anonymous · Accepted solution]

@amichel We have a feature request to add structured streaming support for Tibco EMS and JMS. Unfortunately, it's yet to be prioritized for the roadmap. 

I would request to file a feature request in our ideas portal https://ideas.databricks.com/ideas/, so that you can interact and receive the updates directly with PM team. The ideas portal allows the customers to submit enhancement ideas and other customers to vote on their submitted ideas, and also gives the customers a direct line of communication with PM. You can subscribe to status updates as well.