# 消费位点同步

{% hint style="success" %}

#### 
 **消息路由中的消费位点同步**

一端的Consumer实例从Source集群中消费一条消息后，则在远端的Sink集群中，另外一个Consumer实例不应该重复消费到这条消息，做到**“Exactly Once”**的语义，因此需要一种机制来实现**Source集群于Sink集群的消费位点的同步**
{% endhint %}

如下图： 

![消费位点同步](/files/-LmA1dA40EOKTDytSRbu)

> #### **方案一**
>
> 目前，想到的一种方案是将RocketMQ的Source集群中各个Topic的消费位点/进度这块数据Push至Work集群中的一个，由选择到这个Worker进程再转发至RocketMQ的Sink集群


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://rocketmq-1.gitbook.io/rocketmq-connector/jia-gou-she-ji/xiao-fei-wei-dian.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.