kafka-connect-rabbitmq icon indicating copy to clipboard operation
kafka-connect-rabbitmq copied to clipboard

Published 20 hours ago • verified publisher icon jonahharris

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

Open cobolbaby opened this issue 4 years ago • 3 comments

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 avatar Dec 01 '20 07:12 cobolbaby

Ref: https://github.com/cobolbaby/kafka-connect-rabbitmq/commit/528288559ac31bfc866a1346de6c43c4875b9f16

cobolbaby avatar Dec 03 '20 11:12 cobolbaby

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

jonahharris avatar Dec 03 '20 14:12 jonahharris

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

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

Thanks. :smile:

Matesanz avatar Oct 22 '21 10:10 Matesanz