Zookeeper Listener分析

KafkaController会通过zookeeper监控整个Kafka集群的运行状态，响应管理员的指令，通过在指定znode添加listener, 监听该znode的数据或者子节点等变化 一 TopicChangeListener def handleChildChange(parentPath : String, children : java.util.List[String]) {   i

>>阅读原文<<