Connectors

Overview

This page is the English counterpart of the Chinese Connectors guide. It summarizes cluster edition operation, deployment, integration, and high-availability maintenance while keeping the document path aligned with the Chinese documentation structure.

How To Use This Page

• Follow the same operation order as the Chinese source page.
• Keep configuration values, topic names, ports, commands, and file paths consistent with your deployment environment.
• Screenshots and diagrams reuse the Chinese documentation image directory so assets are maintained in one place.
• For production changes, validate the operation in a test environment before applying it online.

Reference Commands And Configuration

The following snippets are preserved from the source guide because commands, configuration keys, and protocol examples should remain exact.

> broker(bootstrap.servers): 127.0.0.1:9092,127.0.0.2:9092
> 键序列化 (key.serializer): org.apache.kafka.common.serialization.StringSerializer
> 值序列化 (value.serializer): org.apache.kafka.common.serialization.StringSerializer
> 写入确认方式(acks): -1
> 批量发送消息大小(batch.size): 16384
> 等待消息入批的最长时间(linger.ms): 0
> 消息缓冲内存大小(buffer.memory): 33554432
> 消息压缩类型(compression.type): none
> 消息重试次数(retries): 0
> 重试间隔时间(retry.backoff.ms): 100     (毫秒)
> ```

```json
> 生产者组(producer_group): producer_group
> 服务地址(namesrv_addr): 127.0.0.1:9876
> 实例名称(instance_name): default
> 发送失败重试次数(retrys_failed): 2
> 发送失败等待时间(retry_async_failed): 2
> ```

```json
> 连接主机（host）: localhost
> 连接端口（port）: 5762
> 虚拟主机（vhost）: /
> 用户名（username）: guest
> 密码（password）: guest
> 自动恢复连接（automaticRecovery）: true
> 拓扑结构恢复（topologyRecovery）: true
> 网络恢复间隔（networkRecoveryInterval）: 5000
> ```

## Shared Screenshots

The English documentation reuses the screenshots from the Chinese source page. UI labels in screenshots may remain Chinese.

<img src="../../../cluster/images/connectors/connect-test.png" alt="Reference screenshot 1" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/shared/kafka-new.png" alt="Reference screenshot 2" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/kafka-test-success.png" alt="Reference screenshot 3" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/kafka-test-error.png" alt="Reference screenshot 4" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/rocketmq-lianjie.png" alt="Reference screenshot 5" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/rocketmq-new.png" alt="Reference screenshot 6" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/rabbitmq-lianjie.png" alt="Reference screenshot 7" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/rabbitmq-new.png" alt="Reference screenshot 8" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/webhook-lianjie.png" alt="Reference screenshot 9" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/webhook-new.png" alt="Reference screenshot 10" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/webhook-new-1.png" alt="Reference screenshot 11" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />

<img src="../../../cluster/images/connectors/mqtt-new.png" alt="Reference screenshot 12" style="border:1px solid #ccc;border-radius:6px;margin:8px 0;" />