alibaba/canal · error · CanalClientException

Start RabbitMQ producer error

Error message

Start RabbitMQ producer error

What it means

Error "Start RabbitMQ producer error" thrown in alibaba/canal.

Source

Thrown at client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java:83

    }

    public void connect() throws CanalClientException {
        ConnectionFactory factory = new ConnectionFactory();
        if (accessKey.length() > 0 && secretKey.length() > 0) {
            factory.setCredentialsProvider(new AliyunCredentialsProvider(accessKey, secretKey, resourceOwnerId));
        } else {
            factory.setUsername(username);
            factory.setPassword(password);
        }
        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);
        }
    }

    @Override
    public void disconnect() throws CanalClientException {
        if (connect != null) {
            try {
                connect.close();
            } catch (IOException e) {
                throw new CanalClientException("stop connect error", e);
            }
        }
        if (channel != null) {
            try {
                channel.close();
            } catch (IOException | TimeoutException e) {
                throw new CanalClientException("stop channel error", e);
            }

View on GitHub (pinned to 87be50e876)

Solutions

1. Check RabbitMQ host, port, virtualHost, username and password in the connector configuration.
2. Verify network connectivity to the RabbitMQ broker and that the exchange/queue exist with correct permissions.
3. Inspect the nested AMQP exception for the concrete cause (auth failure, connection refused, channel error).

When it happens

Trigger: Thrown at client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java:83 when the library encounters an invalid state.

Common situations: RabbitMQ consumer start failure. Verify host, vhost, credentials, and queue declaration before retry; wrap startup so a partial connection is always closed.

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