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

[onejimmyboy]

config json seems OK， check config again
1：打包rocketmq-connect
2：打包rocketmq-replicator
3：将生成的rocketmq-replicator放在指定位置，
4：启动connect
5：执行上面的post请求

[francisoliverlee]

check doc

[onejimmyboy]

这个意思就是配置目的nameserver吗？(同步到哪个rocketmq，就写把这个rocketmq的nameserver写到这？)相当于dest.endpoint?

[onejimmyboy]

我是用了三台主机，223 、225、B（实现通过主机B上的connect，将223的topic同步到225上）。三台集群装的都有rocketmq服务，B主机除了rocketmq服务外还有rocketmq-connect，connect配置文件中的namesrvAddr写的是localhost，这个配置有问题吗？

[francisoliverlee]

i think so . dest.endpoint Where-Used

[onejimmyboy]

i think so . dest.endpoint Where-Used
那如果是这样，确实能实现从223到225。但是在下发同步任务时的设置的dest,endpoint是不生效的。这感觉还是有问题