diff --git a/rocketmq-client/src/consumer/consumer_impl/re_balance.rs b/rocketmq-client/src/consumer/consumer_impl/re_balance.rs
index 880b44744..79ba9e6a9 100644
--- a/rocketmq-client/src/consumer/consumer_impl/re_balance.rs
+++ b/rocketmq-client/src/consumer/consumer_impl/re_balance.rs
@@ -44,12 +44,6 @@ pub trait RebalanceLocal {
     ) -> bool;
 
     fn remove_unnecessary_pop_message_queue(
-        &mut self,
-        mq: &MessageQueue,
-        pq: &PopProcessQueue,
-    ) -> bool;
-
-    fn remove_unnecessary_pop_message_queue_pop(
         &mut self,
         _mq: &MessageQueue,
         _pq: &PopProcessQueue,
diff --git a/rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_push_impl.rs b/rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_push_impl.rs
index 9ba22eb8c..b356c0d3f 100644
--- a/rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_push_impl.rs
+++ b/rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_push_impl.rs
@@ -243,14 +243,6 @@ impl Rebalance for RebalancePushImpl {
         }
     }
 
-    fn remove_unnecessary_pop_message_queue(
-        &mut self,
-        mq: &MessageQueue,
-        pq: &PopProcessQueue,
-    ) -> bool {
-        todo!()
-    }
-
     fn consume_type(&self) -> ConsumeType {
         ConsumeType::ConsumePassively
     }