alibaba/canal · error · CanalException

Start RabbitMQ producer error

Error message

Start RabbitMQ producer error

What it means

Thrown by CanalRabbitMQProducer.init when establishing the connection/channel and declaring the queue/exchange/binding raises IOException or TimeoutException. The producer could not fully initialize against the broker — connection refused, auth failure, or a queue/exchange declaration that conflicted with an existing one.

Source

Thrown at connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java:98

        }
        factory.setVirtualHost(rabbitMQProperties.getVirtualHost());
        try {
            connect = factory.newConnection();
            channel = connect.createChannel();
            String queue = rabbitMQProperties.getQueue();
            String exchange = rabbitMQProperties.getExchange();
            String deliveryMode = rabbitMQProperties.getDeliveryMode();
            String routingKey = rabbitMQProperties.getRoutingKey();
            if (!StringUtils.isEmpty(queue)) {
                channel.queueDeclare(queue, true, false, false, null);
            }
            if (!StringUtils.isEmpty(queue) && !StringUtils.isEmpty(exchange) && !StringUtils.isEmpty(deliveryMode)
                && !StringUtils.isEmpty(routingKey)) {
                channel.exchangeDeclare(exchange, deliveryMode, true, false, false, null);
                channel.queueBind(queue, exchange, routingKey);
            }
        } catch (IOException | TimeoutException ex) {
            throw new CanalException("Start RabbitMQ producer error", ex);
        }
    }

    private void loadRabbitMQProperties(Properties properties) {
        RabbitMQProducerConfig rabbitMQProperties = (RabbitMQProducerConfig) this.mqProperties;
        // 兼容下<=1.1.4的mq配置
        doMoreCompatibleConvert("canal.mq.servers", "rabbitmq.host", properties);

        String host = PropertiesUtils.getProperty(properties, RabbitMQConstants.RABBITMQ_HOST);
        if (!StringUtils.isEmpty(host)) {
            rabbitMQProperties.setHost(host);
        }
        String vhost = PropertiesUtils.getProperty(properties, RabbitMQConstants.RABBITMQ_VIRTUAL_HOST);
        if (!StringUtils.isEmpty(vhost)) {
            rabbitMQProperties.setVirtualHost(vhost);
        }
        String exchange = PropertiesUtils.getProperty(properties, RabbitMQConstants.RABBITMQ_EXCHANGE);
        if (!StringUtils.isEmpty(exchange)) {

View on GitHub (pinned to 87be50e876)

Solutions

1. Verify broker reachability, credentials, and vhost for the producer.
2. Ensure queue/exchange declaration parameters match any pre-existing resources (durable, type) — RabbitMQ rejects conflicting redeclarions.
3. Confirm the deliveryMode/routingKey values are valid and the exchange type string is correct.
4. Retry init for transient broker outages.

Example fix

// before
try {
    ...
    channel.queueDeclare(queue, true, false, false, null);
    channel.exchangeDeclare(exchange, deliveryMode, true, false, false, null);
} catch (IOException | TimeoutException ex) {
    throw new CanalException("Start RabbitMQ producer error", ex);
}

// after — surface the failing resource in the error
try {
    channel.queueDeclare(queue, true, false, false, null);
} catch (IOException ex) {
    throw new CanalException("queueDeclare failed for " + queue, ex);
}

if (StringUtils.isEmpty(rabbitMQProperties.getHost()))
    throw new IllegalStateException("rabbitmq host missing");
if (!StringUtils.isEmpty(queue) && !StringUtils.isEmpty(exchange)) {
    // ensure deliveryMode is a valid exchange type (direct, topic, fanout, headers)
}

try {
    channel.queueDeclare(queue, true, false, false, null);
} catch (IOException ex) {
    throw new CanalException("queueDeclare failed for " + queue, ex);
}

When it happens

Trigger: newConnection/createChannel or channel.queueDeclare/exchangeDeclare/queueBind (lines ~88-96) throw IOException/TimeoutException. Causes: broker unreachable; credentials/vhost wrong; declaring a queue/exchange with parameters that conflict with an existing one (e.g. durable mismatch); passive declaration of a non-existent exchange.

Common situations: Wrong rabbitmq.host/credentials; queue already exists with different durability/params; exchange deliveryMode typo; broker down during producer init; permission denied to declare resources.

Related errors

• Start RabbitMQ producer error
• Start RocketMQ producer error
• Subscript pulsar consumer error
• failed to parse host
• Stop RabbitMQ producer error

AI-assisted analysis of alibaba/canal@87be50e876 (2026-08-14). Data as JSON: /api/errors/d5be2221ec405367. Report an issue: GitHub.