From cfcaa860d19a46834515e5dfadfa3f2d713340e0 Mon Sep 17 00:00:00 2001 From: mxsm Date: Fri, 7 Feb 2025 14:11:05 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#2531]=E2=9A=A1=EF=B8=8FOptimize=20Que?= =?UTF-8?q?ryAssignmentProcessor=20do=5Fload=5Fbalance=F0=9F=9A=80=20(#253?= =?UTF-8?q?2)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/processor/query_assignment_processor.rs | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/rocketmq-broker/src/processor/query_assignment_processor.rs b/rocketmq-broker/src/processor/query_assignment_processor.rs index dcb0f6c8..879b2985 100644 --- a/rocketmq-broker/src/processor/query_assignment_processor.rs +++ b/rocketmq-broker/src/processor/query_assignment_processor.rs @@ -252,11 +252,8 @@ impl QueryAssignmentProcessor { .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 \