拨开kafka 的外衣

拨开kafka 的外套
def main(args: Array[String]): Unit

?main是万恶之源， 咱们就从这里开始。

?

      val props = Utils.loadProps(args(0))      val serverConfig = new KafkaConfig(props)

?这里加载一些乱七八糟的配置，即是用了 config 目录下的配置。

?

val kafkaServerStartble = new KafkaServerStartable(serverConfig)

?这句相当于初始化整个 kafka?

      Runtime.getRuntime().addShutdownHook(new Thread() {        override def run() = {          kafkaServerStartble.shutdown          kafkaServerStartble.awaitShutdown        }      });

?给jvm 加上一个hook ，此方法的作用是让jvm 在退出之前干这个， 干什么的 ，shutdown kafka。

?

      kafkaServerStartble.startup      kafkaServerStartble.awaitShutdown

?好， kafka开始。

over?

外衣脱掉了，是否索然无味， 是的， 我也这么认为，下一章着重讲讲，kafka broker 启动都干了些什么。

?