MINOR: log when controller begins processing logdir failure event
Reviewers: Jun Rao
@@ -336,10 +336,12 @@ class KafkaController(val config: KafkaConfig, zkClient: KafkaZkClient, time: Ti
/*
* This callback is invoked by the controller's LogDirEventNotificationListener with the list of broker ids who
* have experienced new log directory failures. In response the controller should send LeaderAndIsrRequest
- * to all these brokers to query the state of their replicas
+ * to all these brokers to query the state of their replicas. Replicas with an offline log directory respond with
+ * KAFKA_STORAGE_ERROR, which will be handled by the LeaderAndIsrResponseReceived event.
*/
private def onBrokerLogDirFailure(brokerIds: Seq[Int]) {
// send LeaderAndIsrRequest for all replicas on those brokers to see if they are still online.
+ info(s"Handling log directory failure for brokers ${brokerIds.mkString(",")}")
val replicasOnBrokers = controllerContext.replicasOnBrokers(brokerIds.toSet)
replicaStateMachine.handleStateChanges(replicasOnBrokers.toSeq, OnlineReplica)
}
