[ISSUE #113]🐛Fix unregister broker fail(request code 104)

mxsm · Jan 26, 2024 · 239bf9e · 239bf9e
1 parent e07791c
commit 239bf9e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rocketmq-namesrv/src/route/route_info_manager.rs b/rocketmq-namesrv/src/route/route_info_manager.rs
@@ -1005,7 +1005,7 @@ impl RouteInfoManager {
         reduced_broker: HashSet<String>,
     ) {
         let mut delete_topic = HashSet::new();
-        while let Some((topic, queue_data_map)) = self.topic_queue_table.iter_mut().next() {
+        for (topic, queue_data_map) in self.topic_queue_table.iter_mut() {
             for broker_name in &removed_broker {
                 if let Some(removed_qd) = queue_data_map.remove(broker_name) {
                     println!(