通过 kafka 的启动脚本可知,kafka server 的启动由 kafka.Kafka 类的完成。核心代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
val props = Utils.loadProps(args(0))
// 载入,解析 配置文件 properties val serverConfig = new KafkaConfig(props) KafkaMetricsReporter.startReporters(serverConfig.props) val kafkaServerStartable = new KafkaServerStartable(serverConfig)