Zookeeper Listener分析

KafkaController會通過zookeeper監控整個Kafka集羣的運行狀態，響應管理員的指令，通過在指定znode添加listener, 監聽該znode的數據或者子節點等變化 一 TopicChangeListener def handleChildChange(parentPath : String, children : java.util.List[String]) {   i

>>阅读原文<<