Skip to content

Commit

Permalink
Update 01RocketMQ Connect Overview.md (#639)
Browse files Browse the repository at this point in the history
  • Loading branch information
chi3316 authored May 6, 2024
1 parent 58362f9 commit 2e875f6
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,15 +20,15 @@ RocketMQ Connect是一个独立的的分布式,可伸缩,容错的系统,

##### CDC

CDC作为ETL模式之一,可以近乎实时的捕获增量数据库INSERT、UPDATE,DELETE变化,RocketMQ Connect流试数据传输,具备高可用,低延时等特性,通过Connector很容易实现CDC。
CDC作为ETL模式之一,可以近乎实时的捕获增量数据库INSERT、UPDATE,DELETE变化,RocketMQ Connect流式数据传输,具备高可用,低延时等特性,通过Connector很容易实现CDC。

### Connector 部署

创建Connector,一般通过配置即可完成,Connector包含逻辑的Connector连接器和执行数据复制的Task(即物理线程),如下图所示,两个Connector连接器和它们对应的运行Task任务。

![RocketMQ Connect任务模型1](../picture/32rocketmq-connect/deploy1.png)

一个Connector也可以同时运行多个任务,提高Connector的并行度,例如下图所示的Hudi Sink Connector有2个任务,每个任务处理不同的分片数据,从而Connector的并行度,进而提高处理性能。
一个Connector也可以同时运行多个任务,提高Connector的并行度,例如下图所示的Hudi Sink Connector有2个任务,每个任务处理不同的分片数据,从而提高Connector的并行度,进而提高处理性能。

![RocketMQ Connect任务模型2](../picture/32rocketmq-connect/deploy2.png)

Expand Down

0 comments on commit 2e875f6

Please sign in to comment.