Can we use RocketMQ Connect to synchronize real-time messages from cluster A to cluster B?

[penghuazhou]

Can we use RocketMQ Connect to synchronize real-time messages from cluster A to cluster B?

https://mp.weixin.qq.com/s/icV0buF-EcEX0rgGmMK8MA

[onejimmyboy]

我也想知道，但是看了rocketmq connect中并没有完整的案例，如何实现。楼主有找到方案吗？

[penghuazhou]

shoud use RocketMQ Connect. @onejimmyboy

[onejimmyboy]

我使用的是rocketmq-replicator ，为啥我设置的dest.cluster不生效啊？
方案：将集群A同步到集群B，
步骤
1：第三台主机host1启动rocketmq-broker&rocketmq-namesrv，和rocketmq-connect
2：按照rocketmq-replicator 写的执行同步任务，如下图：

3：src.endpoint确实生效啦，从A获取T2的数据，但是没有同步到B集群，而是同步到了host1其中集群上了，感觉这种不对，dest.endponit没有生效，到底是什么原因呐

[francisoliverlee]

try replicator in RockeMQ Connect

[onejimmyboy]

我使用的是rocketmq-replicator ，为啥我设置的dest.cluster不生效啊？
方案：将集群A同步到集群B，
步骤
1：第三台主机host1启动rocketmq-broker&rocketmq-namesrv，和rocketmq-connect
2：按照rocketmq-replicator 写的执行同步任务，如下图：

3：src.endpoint确实生效啦，从A获取T2的数据，但是没有同步到B集群，而是同步到了host1其中集群上了，感觉这种不对，dest.endponit没有生效，到底是什么原因呐

[francisoliverlee]

config json seems OK， check config again