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