diff --git a/src/kvstore/Listener.cpp b/src/kvstore/Listener.cpp
index ab2858f9d..f2f84d162 100644
--- a/src/kvstore/Listener.cpp
+++ b/src/kvstore/Listener.cpp
@@ -237,6 +237,7 @@ std::pair<int64_t, int64_t> Listener::commitSnapshot(const std::vector<std::stri
     }
     if (finished) {
         CHECK(!raftLock_.try_lock());
+        leaderCommitId_ = committedLogId;
         lastApplyLogId_ = committedLogId;
         persist(committedLogId, committedLogTerm, lastApplyLogId_);
         LOG(INFO) << idStr_ << "Listener succeeded apply log to " << lastApplyLogId_;
diff --git a/src/kvstore/Listener.h b/src/kvstore/Listener.h
index 12769e786..d05a8b07a 100644
--- a/src/kvstore/Listener.h
+++ b/src/kvstore/Listener.h
@@ -110,6 +110,7 @@ class Listener : public raftex::RaftPart {
     }
 
     void cleanup() override {
+        leaderCommitId_ = 0;
         lastApplyLogId_ = 0;
         persist(0, 0, lastApplyLogId_);
     }