[ISSUE #6264]Add updateBrokerConfig admin command

CHANGELOG.md

@@ -11,6 +11,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - **feat(tools):** Add `broker` command group with `GetBrokerConfigSubCommand` for querying broker configuration by broker address or cluster, with optional `--keyPattern` regex filtering
 - **feat(tools):** Add `CleanExpiredCQSubCommand` under broker commands with broker/cluster/topic target scan, dry-run preview, and cleanup summary reporting
+- **feat(tools):** Add `UpdateBrokerConfigSubCommand` under broker commands with single/multi key updates, value validation, broker or cluster targeting, old/new diff display, and rollback on partial failures
 - **test(remoting):** Add comprehensive test coverage for `GetMaxOffsetRequestHeader` including required fields, optional nested headers, trait implementation methods, and edge cases
 - **feat(tools):** Add `SetConsumeModeSubCommand` for setting consumer group consumption mode (PULL/POP) ([#5650](https://github.com/mxsm/rocketmq-rust/issues/5650))
 - **feat(tools):** Add `ListAclSubCommand` for ACL enumeration and subject filtering ([#5663](https://github.com/mxsm/rocketmq-rust/issues/5663))

rocketmq-tools/rocketmq-admin/rocketmq-admin-core/src/commands.rs

@@ -212,6 +212,11 @@ impl CommandExecute for ClassificationTablePrint {
                 command: "switchTimerEngine",
                 remark: "Switch the engine of timer message in broker.",
             },
+            Command {
+                category: "Broker",
+                command: "updateBrokerConfig",
+                remark: "Update broker config by broker or cluster.",
+            },
             Command {
                 category: "Consumer",
                 command: "consumerStatus",

rocketmq-tools/rocketmq-admin/rocketmq-admin-core/src/commands/broker_commands.rs

@@ -19,6 +19,7 @@ mod get_broker_config_sub_command;
 mod reset_master_flush_offset_sub_command;
 mod send_msg_status_sub_command;
 mod switch_timer_engine_sub_command;
+mod update_broker_config_sub_command;
 mod update_cold_data_flow_ctr_group_config_sub_command;
 
 use std::sync::Arc;
@@ -34,6 +35,7 @@ use crate::commands::broker_commands::get_broker_config_sub_command::GetBrokerCo
 use crate::commands::broker_commands::reset_master_flush_offset_sub_command::ResetMasterFlushOffsetSubCommand;
 use crate::commands::broker_commands::send_msg_status_sub_command::SendMsgStatusSubCommand;
 use crate::commands::broker_commands::switch_timer_engine_sub_command::SwitchTimerEngineSubCommand;
+use crate::commands::broker_commands::update_broker_config_sub_command::UpdateBrokerConfigSubCommand;
 use crate::commands::broker_commands::update_cold_data_flow_ctr_group_config_sub_command::UpdateColdDataFlowCtrGroupConfigSubCommand;
 use crate::commands::CommandExecute;
 
@@ -94,6 +96,13 @@ pub enum BrokerCommands {
         long_about = None,
     )]
     UpdateColdDataFlowCtrGroupConfig(UpdateColdDataFlowCtrGroupConfigSubCommand),
+
+    #[command(
+        name = "updateBrokerConfig",
+        about = "Update broker config by special broker or all brokers in cluster.",
+        long_about = None,
+    )]
+    UpdateBrokerConfigSubCommand(UpdateBrokerConfigSubCommand),
 }
 
 impl CommandExecute for BrokerCommands {
@@ -107,6 +116,7 @@ impl CommandExecute for BrokerCommands {
             BrokerCommands::SendMsgStatus(value) => value.execute(rpc_hook).await,
             BrokerCommands::SwitchTimerEngine(value) => value.execute(rpc_hook).await,
             BrokerCommands::UpdateColdDataFlowCtrGroupConfig(value) => value.execute(rpc_hook).await,
+            BrokerCommands::UpdateBrokerConfigSubCommand(cmd) => cmd.execute(rpc_hook).await,
         }
     }
 }