读书人

拨开kafka 的外衣

发布时间: 2013-02-19 11:11:40 作者: rapoo

拨开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 启动都干了些什么。

?

读书人网 >开源软件

热点推荐