Skip to content

Source Connector doesn't support DLX #11

@augustovanderley

Description

@augustovanderley

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.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions