[ISSUE #2531]⚡️Optimize QueryAssignmentProcessor do_load_balance🚀 (#2532

)
mxsm · Feb 7, 2025 · cfcaa86 · cfcaa86
1 parent 60daed9
commit cfcaa86
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/rocketmq-broker/src/processor/query_assignment_processor.rs b/rocketmq-broker/src/processor/query_assignment_processor.rs
@@ -252,11 +252,8 @@ impl<MS: MessageStore> QueryAssignmentProcessor<MS> {
                     .broker_runtime_inner
                     .consumer_manager()
                     .get_consumer_group_info(consumer_group);
-                let mut cid_all = if let Some(consumer_group_info) = consumer_group_info {
-                    consumer_group_info.get_all_client_ids()
-                } else {
-                    vec![]
-                };
+                let mut cid_all =
+                    consumer_group_info.map_or_else(Vec::new, |info| info.get_all_client_ids());
                 if cid_all.is_empty() {
                     warn!(
                         "QueryLoad: no assignment for group[{}] topic[{}], get consumer id list \