Skip to content
Permalink
Browse files
ZookeeperMetaDataCollector init method add zk digest acl support (#911)
  • Loading branch information
sagexueqi committed Jul 1, 2022
1 parent 02d36df commit ebfa2f7b757c46c84c2fac34d555d2847b433e4c
Showing 1 changed file with 9 additions and 1 deletion.
@@ -53,7 +53,15 @@ public void init() {
group = Constants.PATH_SEPARATOR + group;
}
root = group;
client = CuratorFrameworkFactory.newClient(url.getAddress(), new ExponentialBackoffRetry(1000, 3));
CuratorFrameworkFactory.Builder builder = CuratorFrameworkFactory.
builder()
.connectString(url.getAddress())
.retryPolicy(new ExponentialBackoffRetry(1000, 3));
String userInformation = url.getUserInformation();
if (userInformation != null && userInformation.length() > 0) {
builder = builder.authorization("digest", userInformation.getBytes());
}
client = builder.build();
client.start();
}

0 comments on commit ebfa2f7

Please sign in to comment.