# Connector

{% hint style="success" %}

### **Message Connector**

连接器实例属于逻辑概念，其负责维护特定数据系统的相关配置，比如链接地址、需要同步哪些数据等信息；在connector 实例被启动后，connector可以根据配置信息，对解析任务进行拆分，分配出task。这么做的目的是为了提高并行度，提升处理效率。
{% endhint %}

![Connector 概念图](/files/-LtVAVs-QITTHq7nGqam)

## Connector 两个重要概念

* **Connector**

  Connector的入口，**负责管理Task的配置和创建**，TaskClass返回实际要创建的Task，通过TaskConfigs返回Task的配置信息，这个返回的配置是一个list，创建Task的数量就是根据返回的config列表的数量。
* **Task**

  ```
    ****解析数据源数据，并负责在数据源和RocketMQ Broker之间拷贝数据
  ```

## **Connector 示例**

* **\[**&#x72;ocketmq-connecto&#x72;**]\(**<https://github.com/apache/rocketmq-externals/tree/master/rocketmq-connect>**)**
* **\[**&#x72;ocketmq-mysq&#x6C;**]\(**<https://github.com/apache/rocketmq-externals/tree/master/rocketmq-mysql>**)**
* **\[**&#x72;ocketmq-connect-rabbitm&#x71;**]\(**<https://github.com/apache/rocketmq-externals/tree/master/rocketmq-connect-rabbitmq>**)**
* **\[**&#x72;ocketmq-connect-kafk&#x61;**]\(**<https://github.com/apache/rocketmq-externals/tree/master/rocketmq-connect-kafka>**)**
* **\[**&#x72;ocketmq-connect-activem&#x71;**]\(**<https://github.com/apache/rocketmq-externals/tree/master/rocketmq-connect-activemq>**)**

## **Quick Start**

{% content-ref url="/pages/-Lm4BNIguLIj48\_t9viz" %}
[前期准备](/rocketmq-connector/quick-start/qian-qi-zhun-bei.md)
{% endcontent-ref %}


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://rocketmq-1.gitbook.io/rocketmq-connector/jia-gou-she-ji/connector.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.