alibaba/canal · error · CanalClientException

Start RabbitMQ producer error

Error message

Start RabbitMQ producer error

What it means

Thrown by CanalRabbitMQConsumer.connect (the message says 'producer' but this is the consumer) when ConnectionFactory.newConnection() or createChannel() throws IOException or TimeoutException. The RabbitMQ broker could not be reached, refused the connection, or did not respond in time.

Source

Thrown at connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java:106

            factory.setPassword(password);
        }
        // 解析出端口 modified by 16075140
        if (nameServer != null && nameServer.contains(":")) {
            String[] serverHostAndPort = AddressUtils.splitIPAndPort(nameServer);
            factory.setHost(serverHostAndPort[0]);
            factory.setPort(Integer.parseInt(serverHostAndPort[1]));
        } else {
            factory.setHost(nameServer);
        }

        factory.setAutomaticRecoveryEnabled(true);
        factory.setNetworkRecoveryInterval(5000);
        factory.setVirtualHost(vhost);
        try {
            connect = factory.newConnection();
            channel = connect.createChannel();
        } catch (IOException | TimeoutException e) {
            throw new CanalClientException("Start RabbitMQ producer error", e);
        }

        // 不存在连接 则重新连接
        if (connect == null) {
            this.connect();
        }

        Consumer consumer = new DefaultConsumer(channel) {

            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
                                       byte[] body) throws IOException {

                if (body != null) {
                    channel.basicAck(envelope.getDeliveryTag(), process(body));
                }
            }
        };

View on GitHub (pinned to 87be50e876)

Solutions

1. Verify rabbitmq.host/rabbitmq.port point to a reachable broker and that the AMQP port is open.
2. Confirm credentials and the virtual host are correct and that the user has access to the vhost.
3. RabbitMQ's factory has automaticRecoveryEnabled=true already set; retry connect() after a brief delay for transient broker outages.
4. Increase connection timeout if handshakes are slow under load.

Example fix

// before
try {
    connect = factory.newConnection();
    channel = connect.createChannel();
} catch (IOException | TimeoutException e) {
    throw new CanalClientException("Start RabbitMQ producer error", e);
}

// after — include broker detail and retry transient failures
factory.setConnectionTimeout(10000);
int attempts = 0;
while (attempts++ < 3) {
    try {
        connect = factory.newConnection();
        channel = connect.createChannel();
        break;
    } catch (IOException | TimeoutException e) {
        if (attempts >= 3) throw new CanalClientException(
            "Start RabbitMQ consumer error [host=" + nameServer + "]: " + e.getMessage(), e);
    }
}

if (StringUtils.isEmpty(nameServer)) throw new IllegalStateException("rabbitmq host missing");
factory.setConnectionTimeout(10000);

int attempts = 0;
while (attempts++ < 3) {
    try {
        connect = factory.newConnection();
        channel = connect.createChannel();
        break;
    } catch (IOException | TimeoutException e) {
        if (attempts >= 3) throw new CanalClientException("Start RabbitMQ consumer error", e);
    }
}

When it happens

Trigger: factory.newConnection() / connect.createChannel() at lines 100-101 fail. Causes: wrong host/port; RabbitMQ broker down; auth credentials rejected; virtual host does not exist; firewall blocking the AMQP port; broker too slow to complete the handshake (TimeoutException).

Common situations: Misconfigured rabbitmq.host or rabbitmq.virtual.host; broker restart during consumer startup; wrong credentials; AMQP port (5672) blocked by a firewall/security group; high broker load causing handshake timeout.

Related errors

• Start RabbitMQ producer error
• Subscript pulsar consumer error
• Start RocketMQ producer error
• Pulsar Consumer subscriptName required
• Receive pulsar batch message error

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