fix(cli/deploy): override "controller.quorum.bootstrap.servers"

Signed-off-by: Ning Yu <[email protected]>
AutoMQ · Jan 3, 2025 · 552fb77 · 552fb77
1 parent dc36423
commit 552fb77
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/automq-shell/src/main/java/com/automq/shell/commands/cluster/Deploy.java b/automq-shell/src/main/java/com/automq/shell/commands/cluster/Deploy.java
@@ -159,6 +159,7 @@ private static void appendCommonConfigsOverride(StringBuilder sb, ClusterTopolog
         sb.append("--override cluster.id=").append(topo.getGlobal().getClusterId()).append(" ");
         sb.append("--override node.id=").append(node.getNodeId()).append(" ");
         sb.append("--override controller.quorum.voters=").append(getQuorumVoters(topo)).append(" ");
+        sb.append("--override controller.quorum.bootstrap.servers=").append(getBootstrapServers(topo)).append(" ");
         sb.append("--override advertised.listeners=").append("PLAINTEXT://").append(node.getHost()).append(":9092").append(" ");
     }
 
@@ -181,4 +182,14 @@ private static String getQuorumVoters(ClusterTopology topo) {
             .map(node -> node.getNodeId() + "@" + node.getHost() + ":9093")
             .collect(Collectors.joining(","));
     }
+
+    private static String getBootstrapServers(ClusterTopology topo) {
+        List<Node> nodes = topo.getControllers();
+        if (!(nodes.size() == 1 || nodes.size() == 3)) {
+            throw new IllegalArgumentException("Only support 1 or 3 controllers");
+        }
+        return nodes.stream()
+            .map(node -> node.getHost() + ":9093")
+            .collect(Collectors.joining(","));
+    }
 }