kafka-connect-rabbitmq
kafka-connect-rabbitmq copied to clipboard
Source Connector doesn't support DLX
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.