Skip to content

Commit 732b3f8

Browse files
Chillax-0v0superhx
authored andcommitted
fix(cli/deploy): override "controller.quorum.bootstrap.servers"
Signed-off-by: Ning Yu <[email protected]>
1 parent 8189d89 commit 732b3f8

File tree

1 file changed

+11
-0
lines changed
  • automq-shell/src/main/java/com/automq/shell/commands/cluster

1 file changed

+11
-0
lines changed

Diff for: automq-shell/src/main/java/com/automq/shell/commands/cluster/Deploy.java

+11
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,7 @@ private static void appendCommonConfigsOverride(StringBuilder sb, ClusterTopolog
159159
sb.append("--override cluster.id=").append(topo.getGlobal().getClusterId()).append(" ");
160160
sb.append("--override node.id=").append(node.getNodeId()).append(" ");
161161
sb.append("--override controller.quorum.voters=").append(getQuorumVoters(topo)).append(" ");
162+
sb.append("--override controller.quorum.bootstrap.servers=").append(getBootstrapServers(topo)).append(" ");
162163
sb.append("--override advertised.listeners=").append("PLAINTEXT://").append(node.getHost()).append(":9092").append(" ");
163164
}
164165

@@ -181,4 +182,14 @@ private static String getQuorumVoters(ClusterTopology topo) {
181182
.map(node -> node.getNodeId() + "@" + node.getHost() + ":9093")
182183
.collect(Collectors.joining(","));
183184
}
185+
186+
private static String getBootstrapServers(ClusterTopology topo) {
187+
List<Node> nodes = topo.getControllers();
188+
if (!(nodes.size() == 1 || nodes.size() == 3)) {
189+
throw new IllegalArgumentException("Only support 1 or 3 controllers");
190+
}
191+
return nodes.stream()
192+
.map(node -> node.getHost() + ":9093")
193+
.collect(Collectors.joining(","));
194+
}
184195
}

0 commit comments

Comments
 (0)