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 index 87b83dd2..42bf82d0 100644 --- 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