订阅源库的数据变更,并同步到目标库。
前提条件
- MySQL:源库开启 binlog;
- PG:源库设置
wal_level = logical
; - Mongo:源库需为 ReplicaSet;
- 详情请参考 测试环境搭建。
- MySQL/PG:parallel_type=rdb_merge
- Mongo:parallel_type=mongo
- Redis:parallel_type=redis
-
[filter]、[route] 等配置请参考 配置详解。
-
参考各类型集成测试的 task_config.ini:
- dt-tests/tests/mysql_to_mysql/cdc
- dt-tests/tests/pg_to_pg/cdc
- dt-tests/tests/mongo_to_mongo/cdc
- dt-tests/tests/redis_to_redis/cdc
-
按需修改性能参数:
[pipeline]
buffer_size=16000
checkpoint_interval_secs=10
[sinker]
batch_size=200
[parallelizer]
parallel_size=8