I was able to setup Apache Flink 2.0 to consume from Solace queue.
Are there any plans to have a connector or sample code using the new Flink 2.0 libraries?
I was able to setup Apache Flink 2.0 to consume from Solace queue.
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 . If my response doesn’t make sense for your topic, please react to it with a
.
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.