[rocketmq-replicator] Realize consumption offset synchronization

[Git-Yang]

1. Please describe the feature you are requesting.

• Provide MetaSinkTask, call MetaSinkTask in WorkerDirectTask to write data directly to the target cluster.
• In MetaSinkTask, the updateConsumeOffset method will be called to update the target cluster consumeOffset.

2. Provide any additional detail on your proposed use case for this feature.

• [rocketmq-connect] Support WorkerDirectTask #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?

• should-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）
• Maintain the ConsumeOffset deviation between the target cluster and the source cluster（ISSUE has not been submitted）

[Git-Yang]

@lizhiboo Hello, do you think the above implementation is not in line with the original intention of the community design? Can I have a brief conversation with you?

[lizhiboo]

@lizhiboo Hello, do you think the above implementation is not in line with the original intention of the community design? Can I have a brief conversation with you?

My apologize, I think all tasks is finished.

[odbozhou]

rocketmq-connect already has an independent repository, you can go to this repository to submit PR, issue.
https://github.com/apache/rocketmq-connect