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

Source Connector doesn't support DLX

Open augustovanderley opened this issue 4 years ago • 0 comments

Hello, I'm really new to Kafka Connect and RabbitMQ, so sorry for any mistakes I may write.

I can't make this connector work with a RabbitMQ queue with DLX. It works without a DLX, but we need a DLX in order to send messages to our DLQ.

This is the error I get. Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-dead-letter-exchange' for queue 'myqueue' in vhost '/': received none but current is the value 'myqueue.dlx' of type..., class-id=50, method-id=10)

We tried the confluent Connector and it works with the DLX, but we can't afford to pay a license.

I could contribute to this project, but I don't know what is necessary in order to make it work. I'm open to learn about it.

Thanks in advance.

augustovanderley avatar Dec 09 '20 18:12 augustovanderley