Hi Ivan, Please try to always cc the user mailing list otherwise others won’t see your question :)
You are right by default the Rabbit MQ seems to not support exchanges but take a look at this [1]. I think you can inherit from the RMQSource class and override the setupQueue method to bind to your specific exchange. We are also always open for contributions if you would like to improve it. Unfortunately, we will not invest a lot more time into this connector because we are trying to migrate all connectors to the unified source interface to support batch and streaming executions [2]. I am no real expert with stateful functions but can you maybe add some information about your idea? Best, Fabian [1] https://github.com/apache/flink/blob/33aaabebc63f7a44fb64930f5daf8006ce030752/flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java#L232 <https://github.com/apache/flink/blob/33aaabebc63f7a44fb64930f5daf8006ce030752/flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java#L232> [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface > On 5. Nov 2021, at 09:23, ivan.ros...@agilent.com wrote: > > Hi Fabian, > > Indeed, yes! Thank you. > > Ok, now an actual question. I’m using the RabbitMq connector, and works > great with queues. Looked around and saw no obvious way of consuming from > exchanges. Do you know of another rabbitmq connector that has this feature? > > Also, just now learning about stateful functions. Is there a way to sink to > them from a flink job? > > Thank you very much, > > Ivan > > From: Fabian Paul <fabianp...@ververica.com > <mailto:fabianp...@ververica.com>> > Sent: Friday, November 5, 2021 9:19 AM > To: ROSERO,IVAN (Agilent CHE) <ivan.ros...@agilent.com > <mailto:ivan.ros...@agilent.com>> > Cc: user@flink.apache.org <mailto:user@flink.apache.org> > Subject: Re: How to filter these emails? > > > > External Sender - Use caution opening files, clicking links, or responding to > requests. > > Hi Ivan, > > You can configure your email client to filter for messages going to > user@flink.apache.org <mailto:user@flink.apache.org> and move them into a > separate folder. > > Best, > Fabian
