zhangqiufeng88 opened a new issue, #210:
URL: https://github.com/apache/rocketmq-connect/issues/210
1. 场景是使用rocketmq-opeartor部署了两个rocketmq集群A和B，
将rocketmq-connect容器化部署到集群与rocketmq集群A,B相同的k8s集群中，需求是将rocketmq集群A中的topic同步到rocket集群B.
部署rocketmq-connect时connector-cluster-topic,connector-config-topic,connector-position-topic,connector-offset-topic,replicator-store-topic
这几个topic在集群B已创建
2. rocketmq-connect配置文件是：
# rockermq-connect-runtime-config
workerId=standalone-worker
storePathRootDir=/rocketmq-connect/storeRoot
## Http port for user to access REST API
httpPort=8082
# Rocketmq namesrvAddr
namesrvAddr={集群B的namesrvAddr}
# RocketMQ acl
aclEnable=false
accessKey=rocketmq
secretKey=12345678
#autoCreateGroupEnable=false
clusterName="rocketmqB"
# Source or sink connector jar file dir,The default value is
rocketmq-connect-sample
pluginPaths=/rocketmq-connect/connectors/rocketmq-replicator/target/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar
3.发送请求给rocketmq-runtime,请求内容：
http://{runtimeip}:{runtime-port}/connectors/replicator-test?config={"connector-class":"org.apache.rocketmq.replicator.RmqSourceReplicator","source-rocketmq":"{集群A的namesrvAddr}","target-rocketmq":"{集群B的namesrvAddr}","replicator-store-topic":"replicatorTopic","task-divide-strategy":"0","white-list":"test-2","task-parallelism":"2","source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter","target-cluster":"rocketmqB","source-cluster":"rocketmqA","connect-topicname":"","topic.rename.format":
"rename-${topic}"}
4. 看日志，在集群A和B已成功注册生产者，runtime日志也显示已经连接A,B的broker成功，问题是，topic没有成功从A同步到B集群。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
