Source connector support rabbitmq.routing.key and rabbitmq.exchange

[cobolbaby]

The program currently only supports MQ Basic consume, and does not support consume based on routing key.

Currently the routing strategy of the queue need to be defined in advance. We need to create the binding relationship between the exchange and the queue first, and then create the rabbitmq source connector. It is not convenient for later operation and maintenance. Could provide the relevant support?

[cobolbaby]

Ref: cobolbaby/kafka-connect-rabbitmq@5282885

[jonahharris]

Thank you for this - we will look to merge it in.

[Matesanz]

Hello @jonahharris and @cobolbaby thank you for your work on this project.

Would it be possible to merge @cobolbaby solution into this project?

Thanks. 😄