AdminManager

admin管理类 包含了 元数据缓存和 zk 监听客户端
class AdminManager(val config: KafkaConfig,
val metrics: Metrics,
val metadataCache: MetadataCache,
val zkClient: KafkaZkClient)

1. zk 注册监听处理器
   case EventType.NodeChildrenChanged => zNodeChildChangeHandlers.get(path).foreach(.handleChildChange())
   case EventType.NodeCreated => zNodeChangeHandlers.get(path).foreach(.handleCreation())
   case EventType.NodeDeleted => zNodeChangeHandlers.get(path).foreach(.handleDeletion())
   case EventType.NodeDataChanged => zNodeChangeHandlers.get(path).foreach(.handleDataChange())
2. 监听到的事件放入 事件管理器
   并触发事件 KafkaController::process