Here is an attempt to intuitively explain how ZooKeeper works and how it can used.
1. At a High level
ZooKeeper is a service for sure – that provides access to clients to a tree like structure or a hierarchical namespace as ZooKeeper documentation says. So why we need this tree ? Of course for storing data and hence it is called a “data tree”. Each node of the tree is called a zNode. It uses the standard UNIX notation for file system paths. For example, we use /A/B/C to denote the path to zNode C, where C has B as its parent and B has A as its parent. Here is a sample.
That looks very much like a UNIX file system, right? But here is the terminology
- Each node in the tree is called a zNode
- Every zNode in the tree is identified by a path
- zNode types – persistent and ephemeral
- Each zNode will store a value or data and may be child nodes
- Cannot rename zNodes
- We can add/remove watchers to zNodes.
That’s it, someone rightly said ZooKeeper is Feature-light and you could build recipes on top of it. Take a look at netflix’s curator framework (now a Apache project) – some said this makes using ZooKeeper so much easy from a client perspective.
2. One level deeper
So lets consider another example where goal is to store some configurations in a <K,V> format and make it available across cluster of machines. The <K,V> should be persistent aka disk based and should be HA or Replicated and fault tolerant. ZooKeeper is a natural for this use case.
Want to try this ? – install ZooKeeper locally, get into the bin directory and run the following command
zkCli.sh –server 127.0.0.1:2181 //You should see bunch of information with a prompt finally as below [zk: 127.0.0.1:2181(CONNECTED) 1] //Try the following commands to get a feel [zk: 127.0.0.1:2181(CONNECTED) 1] ls / [zookeeper] zk: 220.127.116.11:2181(CONNECTED) 2] create /zk "value" Created /zk [zk: 192.168.255.133:2181(CONNECTED) 18] create /zk/node1 "node1" Created /zk/node1
Once zNodes are created with the desired path you can use GET and SET to use it as a distributed <K,V> store or hashmap.You can install netflix exhibitor – a UI based supervisor for ZooKeeper with which you can visualize data stored.
3. Now how Kafka uses ZooKeeper?
As of v0.8 Kafka uses zookeeper for storing variety configurations and use them across the cluster in a distributed fashion Lets take 2 simple use cases for which Kafka maintains values in ZooKeeper
- Topics under a broker – /brokers/topics/[topic]
- Next Offset for a Consumer/Topic/Partition combination – /consumers/[groupId]/offsets/[topic]/[partitionId]
Now think about “distributed-ness” Of course configurations like these are replicated and distributed throughout the ZooKeeper ensemble – Leader node and Follower nodes.