offset

leonchen83 · Dec 9, 2023 · e19b2d2 · e19b2d2
1 parent 1728704
commit e19b2d2
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/rdb/RdbParser.java b/src/main/java/com/moilioncircle/redis/replicator/rdb/RdbParser.java
@@ -300,13 +300,13 @@ public long parse() throws IOException {
         // we should set repl_id, repl_offset, repl_stream_db after full sync done to avoid losing data.
         Configuration configuration = replicator.getConfiguration();
 
-        String replId = configuration.getCookie(REPL_ID);
+        String replId = configuration.setCookie(REPL_ID, null);
         if (replId != null) configuration.setReplId(replId);
 
-        String replOffset = configuration.getCookie(REPL_OFFSET);
+        String replOffset = configuration.setCookie(REPL_OFFSET, null);
         if (replOffset != null) configuration.setReplOffset(parseLong(replOffset));
 
-        String replStreamDB = configuration.getCookie(REPL_STREAM_DB);
+        String replStreamDB = configuration.setCookie(REPL_STREAM_DB, null);
         if (replStreamDB != null) configuration.setReplStreamDB(parseInt(replStreamDB));
         return offset;
     }