I'm using Flink RabbitMQ Connector for Sinking Data but using the RMQConnectionConfig object I couldn't find any method to set the type of the exchange (Fanout, Topic, Direct). And also the RMQSink get just name of the queue as the parameter. Is there any way to specify the exchange type?
- Sinking messages in RabbitMQ Soheil Pourbafrani
- Re: Sinking messages in RabbitMQ Oytun Tez