Git-Yang commented on pull request #827: URL: https://github.com/apache/rocketmq-externals/pull/827#issuecomment-941939042
> At first，the origin design is use the target cluster as connector host cluster,In this way, messages can be directly synchronized to another cluster without going through a sink task, and a native format converter is provided in the replicator First of all, thank you for your answer. What you mean is that the read message is directly written to the local cluster (while serving as the target cluster) through RocketMQConverter. I also agree with this approach. My original intention of adding WorkerDirectTask and RmqSinkTask was to follow the design philosophy of openmessage and reduce intermediate storage. Do you think it makes sense? -- 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]
