Reconfigure RocketMQ Broker Parameters

KubeBlocks supports dynamic reconfiguration of 165+ broker parameters via mqadmin updateBrokerConfig. Changes take effect without a broker restart.

Prerequisites

Before proceeding, verify your environment meets these requirements:

• A functional Kubernetes cluster (v1.21+ recommended)
• kubectl v1.21+ installed and configured with cluster access
• Helm installed (installation guide)
• KubeBlocks installed (installation guide)
• RocketMQ Add-on installed and a RocketMQ cluster running (see Quickstart)

Update a Broker Parameter

The following example enables multi-dispatch (enableMultiDispatch), which allows a message to be dispatched to multiple consumer groups simultaneously:

kubectl apply -f - <<EOF
apiVersion: operations.kubeblocks.io/v1alpha1
kind: OpsRequest
metadata:
  name: rocketmq-reconfiguring
  namespace: demo
spec:
  type: Reconfiguring
  clusterName: rocketmq-cluster
  reconfigures:
    - componentName: broker
      parameters:
        - key: enableMultiDispatch
          value: "true"
EOF

Monitor progress:

kubectl get opsrequest rocketmq-reconfiguring -n demo -w

NAME                    TYPE            CLUSTER            STATUS    PROGRESS   AGE
rocketmq-reconfiguring  Reconfiguring   rocketmq-cluster   Succeed   1/1        10s

Verify the parameter was applied inside the broker (replace broker-t9j-0 with your actual broker pod name):

kubectl exec -n demo rocketmq-cluster-broker-t9j-0 -c rocketmq-broker -- \
  bash -c 'export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64 && \
  /home/rocketmq/rocketmq-4.9.6/bin/mqadmin getBrokerConfig \
  -n rocketmq-cluster-namesrv.demo.svc.cluster.local:9876 \
  -b $(hostname -i):10911 2>/dev/null | grep enableMultiDispatch'

enableMultiDispatch=true

Revert a Parameter

Set the parameter back to its default value:

kubectl apply -f - <<EOF
apiVersion: operations.kubeblocks.io/v1alpha1
kind: OpsRequest
metadata:
  name: rocketmq-reconfiguring-revert
  namespace: demo
spec:
  type: Reconfiguring
  clusterName: rocketmq-cluster
  reconfigures:
    - componentName: broker
      parameters:
        - key: enableMultiDispatch
          value: "false"
EOF

Cleanup

kubectl delete opsrequest rocketmq-reconfiguring rocketmq-reconfiguring-revert -n demo --ignore-not-found