GBase南大通用 rtsync同步mysql

GBase南大通用

获取安装包 GBase_RTSync_8.6.26.4_8a.tar.gz

解压：

tar zxvf GBase_RTSync_8.6.26.4_8a.tar.gz

进入配置目录并查看

cd GBase_RTSync_8.6.26.4_8a/conf/

更改配置

vim config_task.xml_bk20220907

包围的都不要，oracle全量调增量用的对mysql同步没用

想同步库这样改（同步库的话所有表结构得一致，mysql表都得有主键）

将模板拷贝给执行文件

cp config_task.xml_bk20220907 config_task.xml

然后执行kafka相关配置

vim config_kafka_mysqlto8a.properties

返回上一级并执行

cd ..

sh RTSyncManagerServer.sh start

启动成功后进入8a集群创建consumer

create kafka consumer test transaction topic mysqlto8a brokers '10.50.62.11:9092,10.50.62.12:9092,10.50.62.24:9092';

启动consumer

start kafka consumer test;

GBase南大通用

 开启consumer(删除前面是drop kafka)

gbase> start kafka consumer test111;

gbase> show kafka consumer test111;

gbase> SHOW TRANSACTION CONSUMER;

gbase> SELECT * FROM information_schema.kafka_consumer_status\G

查询所有已启动的 transaction topic consumer task 的同步状态。

SELECT * FROM information_schema.kafka_consumer_status;

查询所有已启动的 loader topic consumer task 的同步状态。

SELECT * FROM information_schema.kafka_loader_consumer_status;

rtsync最好单独一台服务器

GBase南大通用

内存最好不低于256G

1、查看log下是否同步

tail -f /opt/rtsync/GBase_RTSync_8.6.26.4_8a/logs/Reader_INFOCompontSync.log

查看服务启动jps：SyncToolManagerServer，SyncToolReaderServer