0

我是动物园管理员的新手。我在 Zookeeper 服务器中以独立模式创建了一个节点。这是代码片段。

public Connect(String hostPort, String znode, String filename) throws KeeperException, IOException, InterruptedException {
    this.filename = filename;
    zk = new ZooKeeper(hostPort, 3000, this);

    zk.create(znode, new byte[0],
            ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

现在,当我创建节点时(在上面的代码中),我想在 DIGEST-MD5 模式下使用 SASL 给出身份验证要求。我已在托管的 Zookeeper 服务器中成功配置了所需的配置,但尚未在 Client 中配置。

提前致谢。

4

1 回答 1

0

我找到了一种为 zookeeper 节点启用 sasl 身份验证的方法。这是我使用的代码。

zk.addAuthInfo("digest", "admin:admin".getBytes());
于 2013-04-29T04:12:33.590 回答