[rocketmq-replicator] Add RmqSinkTask

1. Please describe the feature you are requesting.
- Provide RmqSinkTask, call RmqSinkTask in WorkerDirectTask to write data directly to the target cluster.
2. Provide any additional detail on your proposed use case for this feature.
- https://github.com/apache/rocketmq-externals/issues/824
3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?
- nice-to-have
4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:
- Maintain BrokerName mapping（ISSUE has not been submitted）

Start by reading the rocketmq-replicator implementation around WorkerDirectTask and review the related context in issue #824. Determine how RmqSinkTask should write data directly to the target cluster and how the proposed BrokerName mapping sub-task affects the design. Done means the requested task is integrated with WorkerDirectTask and its direct-write behavior is verified.

Written by the indexing model from the issue text.