diff --git a/src/meta-srv/src/handler/keep_lease_handler.rs b/src/meta-srv/src/handler/keep_lease_handler.rs
index 24fa22134b..60a93611be 100644
--- a/src/meta-srv/src/handler/keep_lease_handler.rs
+++ b/src/meta-srv/src/handler/keep_lease_handler.rs
@@ -29,7 +29,7 @@ pub struct KeepLeaseHandler {
 
 impl KeepLeaseHandler {
     pub fn new(kv_store: KvStoreRef) -> Self {
-        let (tx, mut rx) = mpsc::channel(1024);
+        let (tx, mut rx) = mpsc::channel(128);
         common_runtime::spawn_bg(async move {
             while let Some(kv) = rx.recv().await {
                 let mut kvs = vec![kv];