From 3bb786078a02c27fb6895df6a21a2864da57ffda Mon Sep 17 00:00:00 2001
From: niebayes <niebayes@gmail.com>
Date: Fri, 29 Dec 2023 18:13:33 +0800
Subject: [PATCH] fix: CR

---
 src/log-store/src/kafka/client_manager.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/log-store/src/kafka/client_manager.rs b/src/log-store/src/kafka/client_manager.rs
index 6c61ea1b75fe..3a1273ccc679 100644
--- a/src/log-store/src/kafka/client_manager.rs
+++ b/src/log-store/src/kafka/client_manager.rs
@@ -23,7 +23,7 @@ use rskafka::client::producer::{BatchProducer, BatchProducerBuilder};
 use rskafka::client::{Client as RsKafkaClient, ClientBuilder};
 use rskafka::BackoffConfig;
 use snafu::ResultExt;
-use tokio::sync::Mutex as TokioMutex;
+use tokio::sync::Mutex;
 
 use crate::error::{BuildClientSnafu, BuildPartitionClientSnafu, Result};
 
@@ -68,7 +68,7 @@ pub(crate) struct ClientManager {
     client_factory: RsKafkaClient,
     /// A pool maintaining a collection of clients.
     /// Key: a topic. Value: the associated client of the topic.
-    client_pool: TokioMutex<HashMap<Topic, Client>>,
+    client_pool: Mutex<HashMap<Topic, Client>>,
 }
 
 impl ClientManager {
@@ -92,7 +92,7 @@ impl ClientManager {
         Ok(Self {
             config: config.clone(),
             client_factory: client,
-            client_pool: TokioMutex::new(HashMap::new()),
+            client_pool: Mutex::new(HashMap::new()),
         })
     }