Update rocketmq-client/src/consumer/consumer_impl/re_balance/rebalanc…

…e_impl.rs Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
mxsm · Dec 14, 2024 · 29b6f65 · 29b6f65
1 parent f96e676
commit 29b6f65
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_impl.rs b/rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_impl.rs
@@ -273,7 +273,10 @@ where
         is_order: bool,
     ) -> bool {
         let strategy_name = match self.allocate_message_queue_strategy.as_ref() {
-            None => return false,
+            None => {
+                error!("get_rebalance_result_from_broker error: allocate_message_queue_strategy is None.");
+                return false;
+            }
             Some(strategy) => strategy.get_name(),
         };
         let message_queue_assignments = self