Connector

连接器实例属于逻辑概念,其负责维护特定数据系统的相关配置,比如链接地址、需要同步哪些数据等信息。

Message Connector

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

Connector 两个重要概念

  • Connector

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

  • Task

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

Connector 示例

Quick Start

Last updated