kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-5137; Controlled shutdown timeout message improvement
Date Fri, 05 May 2017 04:12:13 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 124ddf577 -> 2448343ed


KAFKA-5137; Controlled shutdown timeout message improvement

Provide correct config details in the log message.

Author: umesh chaudhary <umesh9794@gmail.com>

Reviewers: Dustin Cote <dustin@confluent.io>, Ismael Juma <ismael@juma.me.uk>

Closes #2932 from umesh9794/local


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2448343e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2448343e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2448343e

Branch: refs/heads/trunk
Commit: 2448343edd0ea2e1f1a4cdc325d361913e48ff14
Parents: 124ddf5
Author: umesh chaudhary <umesh9794@gmail.com>
Authored: Fri May 5 05:11:43 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri May 5 05:11:47 2017 +0100

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/KafkaServer.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/2448343e/core/src/main/scala/kafka/server/KafkaServer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/KafkaServer.scala b/core/src/main/scala/kafka/server/KafkaServer.scala
index 19773dc..3c681e4 100755
--- a/core/src/main/scala/kafka/server/KafkaServer.scala
+++ b/core/src/main/scala/kafka/server/KafkaServer.scala
@@ -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
             }
           }


Mime
View raw message