通过ticdc实现 同一个tidb 数据库下的两个表的同步?

数据库 testdb 下有两个表 test1 和test2
表结构如下


CREATE TABLE `test1` (
  `a` varchar(20) ,
  `b` varchar(20) ,
  `c` varchar(50) ,
  `d` varchar(50),
  `e` varchar(50) ,
  `f` decimal(14,4),
  `g` varchar(100) ,
  `h` longtext  ,
  `i` varchar(50) ,
  `g` datetime(3) ,
  `k` varchar(50) ,
  `l` datetime(3) ,
	`aa` varchar(20) ,
  `bb` varchar(20) ,
  `cc` varchar(50) ,
  `dd` varchar(50),
  `ee` varchar(50) ,
  `ff` decimal(14,4),
  `gg` varchar(100) ,
  `hh` longtext ,
  `ii` varchar(50) ,
  `gg` datetime(3) ,
  `kk` varchar(50) ,
  `ll` datetime(3) ,
	
  PRIMARY KEY (`aa`) 

) ENGINE=InnoDB ;


CREATE TABLE `test2` (
  `a` varchar(20) ,
  `b` varchar(20) ,
  `c` varchar(50) ,
  `d` varchar(50),
  `e` varchar(50) ,
  `f` decimal(14,4),
  `g` varchar(100) ,
  `h` longtext COLLATE ,
  `i` varchar(50) ,
  `g` datetime(3) ,
  `k` varchar(50) ,
  `l` datetime(3) ,
  PRIMARY KEY (`a`) ,
  UNIQUE KEY `IX_tb_barcode` (`b`)
) ENGINE=InnoDB ;

说明: test1中的部分字段的数据同步到test2,两个表主键不一样。
如果使用ticdc,各位大拿有什么好的建议?
有没有其他的同步方式?


这样的表结构,符合有效索引的要求吗?

我们表之间同步用的是TiCDC+Kafka+Flink,异构和同构数据库间同步均可以用

https://docs.pingcap.com/zh/tidb/stable/ticdc-overview

上下游表结构需要一致

不一致的话只能TiCDC->Kafka->应用程序 消费了

只弄过上下游一致的同步,主要是复制库;异结构的看能不能通过应用程序处理

cdc目前不支持指定库表名

:thinking:TiCDC支持同一个集群内数据同步么?感觉会有冲突吧。

我理解的 sink 是tidb,需要不同库 。

:thinking:有可能支持,但我没验证过。不过楼主的同集群同数据库,应该TiCDC是支持不了的。

此话题已在最后回复的 60 天后被自动关闭。不再允许新回复。