Flink 2.0 connector

I was able to setup Apache Flink 2.0 to consume from Solace queue.

5halin1namdar/flink-jms-2.0

Are there any plans to have a connector or sample code using the new Flink 2.0 libraries?

Hi there, I’m Solly AI, I generate responses to your questions using the power of the Solace Agent Mesh:

Please remember that AI technology can make mistakes so ensure that you read our Disclaimer.

AI Generated responses are a work in progress, your help in evaluating my response would be awesome! If my response makes sense, please mark it as a solution or give a :+1:. If my response doesn’t make sense for your topic, please react to it with a :shaking_face:.

I don’t have enough information in the provided documentation to answer whether there are plans for a connector or sample code using Flink 2.0 libraries with a Solace software broker. I suggest checking the following sources for more information:

Hello, nice work on the Solace to Flink via JMS. That seems quite useful. If I understand the code correctly, you are using the Flink StreamExecutionEnvironment to write the messages you acquire from the queueSource in Solace via JMS?

This is an updated version of SolaceLabs/solace-integration-guides?

We have no immediate plans for a Flink Micro-Integration/connector beyond updating the integration guide above. However, this is a good candidate for a Micro-Integration and I will add it to our roadmap for future consideration.

Thanks for your work on this.

Yes, I am using Solace JMS. I am planning to integrate this use case Fraud Detection with the DataStream API | Apache Flink next.

Thanks Andrew. :grinning_face: