diff --git a/rocketmq-namesrv/src/route/batch_unregistration_service.rs b/rocketmq-namesrv/src/route/batch_unregistration_service.rs
index 7cce91be..34f9c719 100644
--- a/rocketmq-namesrv/src/route/batch_unregistration_service.rs
+++ b/rocketmq-namesrv/src/route/batch_unregistration_service.rs
@@ -16,6 +16,7 @@
  */
 use rocketmq_remoting::protocol::header::namesrv::broker_request::UnRegisterBrokerRequestHeader;
 use rocketmq_rust::ArcMut;
+use tracing::info;
 use tracing::warn;
 
 use crate::bootstrap::NameServerRuntimeInner;
@@ -53,6 +54,7 @@ impl BatchUnregistrationService {
         let mut rx = self.rx.take().expect("rx is None");
         let limit = 10;
         tokio::spawn(async move {
+            info!(">>>>>>>>BatchUnregistrationService started<<<<<<<<<<<<<<<<<<<");
             loop {
                 let mut unregistration_requests = Vec::with_capacity(limit);
                 tokio::select! {
diff --git a/rocketmq-namesrv/src/route/route_info_manager.rs b/rocketmq-namesrv/src/route/route_info_manager.rs
index 41957824..db1b5be6 100644
--- a/rocketmq-namesrv/src/route/route_info_manager.rs
+++ b/rocketmq-namesrv/src/route/route_info_manager.rs
@@ -1207,6 +1207,7 @@ impl RouteInfoManager {
     //! start client connection disconnected listener
     pub fn start(&self, receiver: broadcast::Receiver<SocketAddr>) {
         let mut inner = self.name_server_runtime_inner.clone();
+        self.un_register_service.mut_from_ref().start();
         let mut receiver = receiver;
         tokio::spawn(async move {
             while let Ok(socket_addr) = receiver.recv().await {