[rocketmq-connect] For replicator design ideas, seek advice.

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?

Start by reading the rocketmq-connect module and tracing the sourceTask and sinkTask flow. Then examine RocketMQConverter, WorkerDirctTask, WokerSourceTask, and WokerSinkTask to compare the proposed direct-forwarding design. The issue is done only when the community provides a decision on the design direction.

Written by the indexing model from the issue text.