diff --git a/internal/controller/automq_controller_b.go b/internal/controller/automq_controller_b.go index a24d62f..92813d8 100644 --- a/internal/controller/automq_controller_b.go +++ b/internal/controller/automq_controller_b.go @@ -261,7 +261,7 @@ func (r *AutoMQReconciler) syncBrokerDeploy(ctx context.Context, obj *infrav1bet "--process.roles", "broker", "--node.id", - fmt.Sprintf("%d", index), + fmt.Sprintf("%d", index+obj.Spec.Controller.Replicas), "--cluster.id", obj.Spec.ClusterID, "--controller.quorum.voters",