allow to subscribe one region multiple times in one stream

Signed-off-by: qupeng <qupeng@pingcap.com>
tikv · Jul 4, 2023 · d7a5672 · d7a5672
1 parent 6ca4a62
commit d7a5672
Show file tree

Hide file tree

Showing 9 changed files with 961 additions and 460 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/components/cdc/src/delegate.rs b/components/cdc/src/delegate.rs
@@ -221,6 +221,9 @@ impl Downstream {
     pub fn get_conn_id(&self) -> ConnId {
         self.conn_id
     }
+    pub fn get_req_id(&self) -> u64 {
+        self.req_id
+    }
 }
 
 #[derive(Default)]
@@ -710,6 +713,7 @@ impl Delegate {
 
             let event = Event {
                 region_id,
+                request_id: downstream.get_req_id(),
                 index,
                 event: Some(Event_oneof_event::Entries(EventEntries {
                     entries: entries_clone.into(),