1.After created the zookeeper cluster, we found all broker cluster topic can be find in zoo1, zoo2, zoo3.
[root@zoo1 zookeeper]# /root/kafka/bin/kafka-topics.sh --describe --zookeeper zoo1:2181 Topic:my-replicated-topic PartitionCount:1 ReplicationFactor:3 Configs: Topic: my-replicated-topic Partition: 0 Leader: 1 Replicas: 2,0,1 Isr: 1 Topic:test PartitionCount:1 ReplicationFactor:1 Configs: Topic: test Partition: 0 Leader: 1 Replicas: 1 Isr: 1 Topic:test123 PartitionCount:1 ReplicationFactor:1 Configs: Topic: test123 Partition: 0 Leader: 1 Replicas: 1 Isr: 1 [root@zoo1 zookeeper]# /root/kafka/bin/kafka-topics.sh --describe --zookeeper zoo2:2181 Topic:my-replicated-topic PartitionCount:1 ReplicationFactor:3 Configs: Topic: my-replicated-topic Partition: 0 Leader: 1 Replicas: 2,0,1 Isr: 1 Topic:test PartitionCount:1 ReplicationFactor:1 Configs: Topic: test Partition: 0 Leader: 1 Replicas: 1 Isr: 1 Topic:test123 PartitionCount:1 ReplicationFactor:1 Configs: Topic: test123 Partition: 0 Leader: 1 Replicas: 1 Isr: 1 [root@zoo1 zookeeper]# /root/kafka/bin/kafka-topics.sh --describe --zookeeper zoo3:2181 Topic:my-replicated-topic PartitionCount:1 ReplicationFactor:3 Configs: Topic: my-replicated-topic Partition: 0 Leader: 1 Replicas: 2,0,1 Isr: 1 Topic:test PartitionCount:1 ReplicationFactor:1 Configs: Topic: test Partition: 0 Leader: 1 Replicas: 1 Isr: 1 Topic:test123 PartitionCount:1 ReplicationFactor:1 Configs: Topic: test123 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
2.Even we shutdown the zoo or any leader of zookeeper cluster, we can see the topic still can be access on other zoo server
3.Zookeeper-shell
[root@zoo1 zookeeper]# /root/kafka/bin/zookeeper-shell.sh zoo1:2181 Connecting to zoo1:2181 Welcome to ZooKeeper! JLine support is disabled WATCHER:: WatchedEvent state:SyncConnected type:None path:null help ZooKeeper -server host:port cmd args stat path [watch] set path data [version] ls path [watch] delquota [-n|-b] path ls2 path [watch] setAcl path acl setquota -n|-b val path history redo cmdno printwatches on|off delete path [version] sync path listquota path rmr path get path [watch] create [-s] [-e] path data acl addauth scheme auth quit getAcl path close connect host:port
4.