[GitHub] [rocketmq-connect] sunxiaojian commented on issue #210: 数据无法同步问题

[GitBox <gi...@apache.org>]

sunxiaojian commented on issue #210:
URL: https://github.com/apache/rocketmq-connect/issues/210#issuecomment-1193894990

   > 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集群。
   
   converter 配置有误，改成 "source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter",


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org