From 64d5cc5b302d2ecaa4059f79868a724b385fc823 Mon Sep 17 00:00:00 2001
From: cuisongliu <cuisongliu@qq.com>
Date: Mon, 14 Oct 2024 01:23:05 +0800
Subject: [PATCH] feat(main):  fix index for broker

Signed-off-by: cuisongliu <cuisongliu@qq.com>
---
 internal/controller/automq_controller_b.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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