加载Log

LogManager 加载Log。

INFO Logs loading complete in 952 ms. (kafka.log.LogManager)

服务注册

znode路径：/brokers/ids/${id}
里面有Broker的对外地址、端口、协议。

读ZK元信息

Reading reply sessionid

启动内部组件

启动
GroupCoordinator
TransactionCoordinator

initial high watermark Appended new epoch entry EpochEntry(

Controller相关

主要是kafka.controller.KafkaController类。

选举

ZK znode /controller

controller_epoch中epoch加1。

连接其他Broker

更新Broker epoch。