Git-Yang opened a new issue #686:
URL: https://github.com/apache/rocketmq-externals/issues/686
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?
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
