diff options
Diffstat (limited to 'zookeeper-server')
| -rw-r--r-- | zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java index 32eabc170e3..4a2c3ea5d96 100644 --- a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java +++ b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java @@ -87,7 +87,9 @@ public class Reconfigurer extends AbstractComponent { } private String connectionSpec(ZookeeperServerConfig config) { - return String.join(",", servers(config)); + return config.server().stream() + .map(server -> server.hostname() + ":" + server.quorumPort()) + .collect(Collectors.joining(",")); } private static List<String> servers(ZookeeperServerConfig config) { |