odbozhou commented on issue #686: URL: https://github.com/apache/rocketmq-externals/issues/686#issuecomment-903399125
> After reading the code of rocketmq connect module, I have some questions to ask for advice. > > 1.The current usage of rocketmq-connect is that transferred to the middle tier by sourceTask, and then transferred to the target cluster by sinkTask. For rocketmq type data sources, can they be directly synchronized to the target cluster？ > > 2.As for RocketMQConverter, I understand whether it is a special processing for rocketmq, which should not be implemented in rocketmq-connect or implemented in RocketMQConverter. Do you have any opinions on this part of the community? >  > > 3.I plan to implement the WorkerDirctTask of direct forwarding by encapsulating WokerSourceTask and WokerSinkTask. Is this method in line with the community development plan? 1. Your understanding is correct. 2. RocketMQConverter is the direct support of rocketmq source and target, and one less data transfer.  3. Of course what you said is also achievable to provide sink and source -- 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]
