ISSUE #6264: Add updateBrokerConfig admin command

Introduce a broker admin subcommand for updating broker
configuration on one broker or across an entire cluster.

Allow either a single key/value pair or multiple KEY=VALUE
entries so operators can apply related config changes in one
operation.

Validate inputs before applying updates, including empty-value
checks and compatibility checks against existing value types,
to reduce avoidable misconfiguration risk.

Show old and new values per broker before execution for safer
change confirmation, and add rollback support for partial
failures to preserve cluster consistency.

Author: willwang-io

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,
         }
     }
 }