Skip to content

Commit 18fb68b

Browse files
committed
Set default Etcd load balancer policy to round_robin
1 parent 2aff8f6 commit 18fb68b

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

uniqueid-etcd/src/main/java/org/lable/oss/uniqueid/etcd/RegistryBasedGeneratorIdentity.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -102,13 +102,10 @@ private RegistryBasedResourceClaim acquireResourceClaim(String registryEntry, in
102102
);
103103
} catch (IOException e) {
104104
if (retries < 3) {
105-
logger.warn(
106-
"Connection to Etcd failed, retrying claim acquisition, attempt " + (retries + 1) + ".",
107-
e
108-
);
105+
logger.warn("Connection to Etcd failed, retrying claim acquisition, attempt {}.", retries + 1, e);
109106
return acquireResourceClaim(registryEntry, retries + 1);
110107
} else {
111-
logger.error("Failed to acquire resource claim after attempt " + (retries + 1) + ".", e);
108+
logger.error("Failed to acquire resource claim after attempt {}.", retries + 1, e);
112109
throw new GeneratorException(e);
113110
}
114111
}
@@ -117,6 +114,7 @@ private RegistryBasedResourceClaim acquireResourceClaim(String registryEntry, in
117114
Client getEtcdConnection() {
118115
return Client.builder()
119116
.endpoints(endpoints.split(","))
117+
.loadBalancerPolicy("round_robin")
120118
.namespace(ByteSequence.from(namespace, StandardCharsets.UTF_8))
121119
.build();
122120
}

0 commit comments

Comments
 (0)