如何在Zookeeper上启用SASL认证层？

Question

我是Zookeeper的新手。我在独立模式下在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认证要求，当我创建节点（在上面的代码）。我已成功配置所需的configurations托管的Zookeeper服务器，并且尚未在客户端中进行配置。

在此先感谢。

Answer 1

我找到了一种为动物园管理员节点启用sasl认证的方法。 这是我使用的代码。

zk.addAuthInfo("digest", "admin:admin".getBytes());