1.视界
1 概述
kafka在启动的时候，初始化了kafka在zk上的相关信息。
2 入口方法
kafka.server.KafkaServer#startup
/** setup zookeeper
* 一个是连接到zk服务器；
* 二是创建根节点。
* 三是创建根节点下的子节点
* */
initZkClient(time)
我们打开看看里面有什么
3 初始化zk相关信息
private def initZkClient(time: Time): Unit = {
info(s"Connecting to zookeeper on ${config.zkConnect}")
def createZkClient(zkConnect: String, isSecure: Boolean) =
KafkaZkClient(zkConnect, isSecure, config.zkSessionTimeoutMs, config.zkConnectionTimeoutMs,
config.zkMaxInFlightRequests, time, name = Some("Kafka server"))
val chrootInd