ZooKeeper(3.4.5)

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.KeeperState;/** * 创建一个基本的ZooKeeper会话实例 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {        final CountDownLatch connectedSignal = new CountDownLatch(1);                /**         * ZooKeeper客户端和服务器会话的建立是一个异步的过程         * 构造函数在处理完客户端的初始化工作后立即返回，在大多数情况下，并没有真正地建立好会话         * 当会话真正创建完毕后，Zookeeper服务器会向客户端发送一个事件通知         */        ZooKeeper zk = new ZooKeeper("192.168.1.109:2181", 5000, new Watcher() {                        @Override            public void PRocess(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    connectedSignal.countDown();                }            }        });        System.out.println("State1: " + zk.getState());    // CONNECTING                connectedSignal.await();                System.out.println("State2: " + zk.getState());    // CONNECTED                zk.close();        System.out.println("State3: " + zk.getState());    // CLOSED    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.KeeperState;/** * 创建一个复用sessionId和sessionPasswd的ZooKeeper对象示例 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);                ZooKeeper zk = new ZooKeeper("192.168.1.109:2181", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    connectedSignal.countDown();                }            }        });                connectedSignal.await();        long sessionId = zk.getSessionId();        byte[] passwd = zk.getSessionPasswd();        zk.close();                        final CountDownLatch anotherConnectedSignal = new CountDownLatch(1);        ZooKeeper newZk = new ZooKeeper(                "192.168.1.109:2181",                 5000,                 new Watcher() {                    @Override                    public void process(WatchedEvent event) {                        if (event.getState() == KeeperState.SyncConnected) {                            anotherConnectedSignal.countDown();                        }                    }                },                sessionId,                 passwd);                anotherConnectedSignal.await();        newZk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;/** * 使用同步API创建一个ZNode节点 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);               ZooKeeper zk = new ZooKeeper("192.168.1.109:2181", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    connectedSignal.countDown();                }            }        });        connectedSignal.await();                String path = zk.create(                "/zk-huey",                 "hello".getBytes(),                 Ids.OPEN_ACL_UNSAFE,                 CreateMode.PERSISTENT        );        System.out.println(path + " is created.");                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;/** * 使用异步API创建一个ZNode节点 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);               ZooKeeper zk = new ZooKeeper("192.168.1.109:2181", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    connectedSignal.countDown();                }            }        });        connectedSignal.await();                zk.create(                "/zk-huey",                 "hello".getBytes(),                 Ids.OPEN_ACL_UNSAFE,                 CreateMode.PERSISTENT_SEQUENTIAL,                new AsyncCallback.StringCallback() {                    @Override                    public void processResult(int rc, String path, Object ctx, String name) {                        // 服务器响应吗                        System.out.println("ResultCode: " + rc);                        // 接口调用时传入API的数据节点的路径参数值                        System.out.println("Znode: " + path);                        // 接口调用时传入API的ctx参数值                        System.out.println("Context: " + (String)ctx);                        // 实际在服务端创建的节点名                        System.out.println("Real Path: " + name);                    }                },                "The Context"        );                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.KeeperState;/** * 使用同步API删除一个ZNode节点 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);               ZooKeeper zk = new ZooKeeper("192.168.1.109:2181", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    connectedSignal.countDown();                }            }        });        connectedSignal.await();                zk.delete("/zk-huey", -1);                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.KeeperState;/** * 使用异步API删除一个ZNode节点 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);               ZooKeeper zk = new ZooKeeper("192.168.1.109:2181", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    connectedSignal.countDown();                }            }        });        connectedSignal.await();                zk.delete(                "/zk-huey",                 -1,                new AsyncCallback.VoidCallback() {                    @Override                    public void processResult(int rc, String path, Object ctx) {                        System.out.println("ResultCode: " + rc);                        System.out.println("Znode: " + path);                        System.out.println("Context: " + (String)ctx);                    }                },                "The Context"        );                zk.close();    }}

package com.huey.dream.demo;import java.util.List;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.KeeperException;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.data.Stat;/** * 使用同步API获取子节点列表 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, null);        zk.register(new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    } else if (event.getType() == EventType.NodeChildrenChanged) {                                            try {                            System.out.println("NodeChildrenChanged.");                            List<String> children = zk.getChildren(event.getPath(), true);                            System.out.println("Children: " + children);                        } catch (KeeperException e) {                            e.printStackTrace();                        } catch (InterruptedException e) {                            e.printStackTrace();                        }                    }                }            }        });        connectedSignal.await();                zk.create("/zk-huey", "root".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        zk.create("/zk-huey/node1", "node1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        zk.create("/zk-huey/node2", "node2".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);                Stat stat = new Stat();        List<String> children = zk.getChildren("/zk-huey",                 true,    // 注册默认的Watcher，当子节点类别发送变更的话，向客户端发送通知                stat    // 用于描述节点状态信息        );        System.out.println("Stat: " + stat);        System.out.println("Children: " + children);                zk.create("/zk-huey/node3", "node3".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);                Thread.sleep(10 * 1000);        zk.close();    }}

结果输出：

Stat: 4294967436,4294967436,1425201236879,1425201236879,0,2,0,0,4,2,4294967438Children: [node2, node1]NodeChildrenChanged.State: CONNECTEDChildren: [node2, node3, node1]

package com.huey.dream.demo;import java.util.List;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.KeeperException;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.data.Stat;/** * 使用异步API获取子节点列表 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, null);        zk.register(new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    } else if (event.getType() == EventType.NodeChildrenChanged) {                                            try {                            System.out.println("NodeChildrenChanged.");                            List<String> children = zk.getChildren(event.getPath(), true);                            System.out.println("Children: " + children);                        } catch (KeeperException e) {                            e.printStackTrace();                        } catch (InterruptedException e) {                            e.printStackTrace();                        }                    }                }            }        });        connectedSignal.await();                zk.create("/zk-huey", "root".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        zk.create("/zk-huey/node1", "node1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        zk.create("/zk-huey/node2", "node2".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);                zk.getChildren("/zk-huey",                 true,                new AsyncCallback.Children2Callback() {                    @Override                    public void processResult(int rc, String path, Object ctx,                            List<String> children, Stat stat) {                        System.out.println("ResultCode: " + rc);                        System.out.println("ZNode: " + path);                        System.out.println("Context: " + ctx);                        System.out.println("Children: " + children);                        System.out.println("Stat: " + stat);                    }                },                "The Context"        );                zk.create("/zk-huey/node3", "node3".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);                Thread.sleep(10 * 1000);        zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;/** * 使用同步API获取节点数据内容 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    }                }            }        });        connectedSignal.await();                zk.create("/zk-huey", "hello".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        byte[] nodeData = zk.getData("/zk-huey", false, null);        System.out.println("NodeData: " + new String(nodeData));                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.data.Stat;/** * 使用异步API获取节点数据内容 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    }                }            }        });        connectedSignal.await();                zk.create("/zk-huey", "hello".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        zk.getData(                "/zk-huey",                 false,                 new AsyncCallback.DataCallback() {                    @Override                    public void processResult(int rc, String path, Object ctx, byte[] data,                            Stat stat) {                        System.out.println("ResultCode: " + rc);                        System.out.println("ZNode: " + path);                        System.out.println("Context: " + ctx);                        System.out.println("NodeData: " + new String(data));                        System.out.println("Stat: " + stat);                    }                },                "The Context"        );                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;/** * 使用同步API更新节点数据内容 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    }                }            }        });        connectedSignal.await();                zk.create("/zk-huey", "hello".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        byte[] nodeData = zk.getData("/zk-huey", false, null);        System.out.println("NodeData: " + nodeData);                zk.setData("/zk-huey", "world".getBytes(), -1);        nodeData = zk.getData("/zk-huey", false, null);        System.out.println("NodeData: " + nodeData);                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.data.Stat;/** * 使用异步API更新节点数据内容 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    }                }            }        });        connectedSignal.await();                zk.create("/zk-huey", "hello".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        byte[] nodeData = zk.getData("/zk-huey", false, null);        System.out.println("NodeData: " + nodeData);                zk.setData(                "/zk-huey",                 "world".getBytes(),                 -1,                new AsyncCallback.StatCallback() {                    @Override                    public void processResult(int rc, String path, Object ctx, Stat stat) {                        System.out.println("ResultCode: " + rc);                        System.out.println("ZNode: " + path);                        System.out.println("Context: " + ctx);                        System.out.println("Stat: " + stat);                    }                },                "The Context"        );                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.data.Stat;/** * 使用同步API判断节点是否存在 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    }                }            }        });        connectedSignal.await();                Stat stat = zk.exists("/zk-huey", false);        if (stat == null) {            zk.create("/zk-huey", "hello".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        } else {            System.out.println("Stat: " + stat);        }                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.AsyncCallback;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher.Event.EventType;import org.apache.zookeeper.Watcher.Event.KeeperState;import org.apache.zookeeper.data.Stat;/** * 使用异步API判断节点是否存在 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                final CountDownLatch connectedSignal = new CountDownLatch(1);        final ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                        @Override            public void process(WatchedEvent event) {                if (event.getState() == KeeperState.SyncConnected) {                    if (event.getType() == EventType.None                            && event.getPath() == null) {                        connectedSignal.countDown();                    }                }            }        });        connectedSignal.await();                zk.exists(                "/zk-huey",                 false,                new AsyncCallback.StatCallback() {                    @Override                    public void processResult(int rc, String path, Object ctx, Stat stat) {                        System.out.println("ResultCode: " + rc);                        System.out.println("ZNode: " + path);                        System.out.println("Context: " + ctx);                        System.out.println("Stat: " + stat);                    }                },                "The Context"        );                zk.close();    }}

package com.huey.dream.demo;import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.ZooDefs.Ids;/** * ZooKeeper权限控制 * @author  huey * @version 1.0  * @created 2015-3-1 */public class ZKDemo {        public static void main(String[] args) throws Exception {                /**         * 使用含有权限信息的zookeeper会话创建数据节点         */        final CountDownLatch connectedSignal = new CountDownLatch(1);        ZooKeeper zk = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {            @Override            public void process(WatchedEvent event) {                connectedSignal.countDown();            }        });        connectedSignal.await();        zk.addAuthInfo("digest", "huey:123".getBytes());        zk.create("/zk-huey", "hello".getBytes(), Ids.CREATOR_ALL_ACL, CreateMode.PERSISTENT);        zk.close();                /**         * 使用无权限信息的zookeeper会话访问含有权限信息的数据节点         */        try {            final CountDownLatch signal = new CountDownLatch(1);            ZooKeeper zk1 = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                @Override                public void process(WatchedEvent event) {                    signal.countDown();                }            });            signal.await();            zk1.getData("/zk-huey", false, null);            System.out.println("NodeData: " + new String(zk1.getData("/zk-huey", false, null)));            zk1.close();        } catch (Exception e) {            System.out.println("Failed to delete Znode: " + e.getMessage());        }                /**         * 使用错误权限信息的zookeeper会话访问含有权限信息的数据节点         */        try {            final CountDownLatch signal = new CountDownLatch(1);            ZooKeeper zk2 = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                @Override                public void process(WatchedEvent event) {                    signal.countDown();                }            });            signal.await();            zk2.addAuthInfo("digest", "huey:abc".getBytes());            System.out.println("NodeData: " + new String(zk2.getData("/zk-huey", false, null)));            zk2.close();        } catch (Exception e) {            System.out.println("Failed to delete Znode: " + e.getMessage());        }                /**         * 使用正确权限信息的zookeeper会话访问含有权限信息的数据节点         */        try {            final CountDownLatch signal = new CountDownLatch(1);            ZooKeeper zk3 = new ZooKeeper("192.168.1.109:2182", 5000, new Watcher() {                @Override                public void process(WatchedEvent event) {                    signal.countDown();                }            });            signal.await();            zk3.addAuthInfo("digest", "huey:123".getBytes());            System.out.println("NodeData: " + new String(zk3.getData("/zk-huey", false, null)));            zk3.close();        } catch (Exception e) {            System.out.println("Failed to delete Znode: " + e.getMessage());        }    }}

结果输出：

Failed to delete Znode: KeeperErrorCode = NoAuth for /zk-hueyFailed to delete Znode: KeeperErrorCode = NoAuth for /zk-hueyNodeData: hello