MINOR: Fix swallowed NPE in KafkaServer.close()
If the server fails to connect to zk, `kafkaScheduler` will be `null`
when closing  `KafkaServer`. The NPE is swallowed so it's
harmless apart from the confusing log noise.
Reviewers: Ismael Juma
@@ -576,6 +576,7 @@ class KafkaServer(val config: KafkaConfig, time: Time = Time.SYSTEM, threadNameP
if (requestHandlerPool != null)
CoreUtils.swallow(requestHandlerPool.shutdown(), this)
+ if (kafkaScheduler != null)
CoreUtils.swallow(kafkaScheduler.shutdown(), this)
if (apis != null)
