Controlled shutdown timeout message improvement
Provide correct config details in the log message.
Author: umesh chaudhary
Reviewers: Dustin Cote Ismael Juma
Closes from umesh9794/local
@@ -458,7 +458,7 @@ class KafkaServer(val config: KafkaConfig, time: Time = Time.SYSTEM, threadNameP
catch {
case ioe: IOException =>
ioException = true
- warn("Error during controlled shutdown, possibly because leader movement took longer than the configured socket.timeout.ms: %s".format(ioe.getMessage))
+ warn("Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: %s".format(ioe.getMessage))
// ignore and try again
}
}
@@ -532,7 +532,7 @@ class KafkaServer(val config: KafkaConfig, time: Time = Time.SYSTEM, threadNameP
case ioe: java.io.IOException =>
channel.disconnect()
channel = null
- warn("Error during controlled shutdown, possibly because leader movement took longer than the configured socket.timeout.ms: %s".format(ioe.getMessage))
+ warn("Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: %s".format(ioe.getMessage))
// ignore and try again
}
}
