kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject [1/3] kafka git commit: KAFKA-2175; Change INFO to DEBUG for socket close on no error; and partition reassignment JSON; reviewed by Gwen Shapira and Joel Koshy
Date Tue, 12 May 2015 22:41:30 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk af5061923 -> 33af0cba3


KAFKA-2175; Change INFO to DEBUG for socket close on no error; and partition reassignment
JSON; reviewed by Gwen Shapira and Joel Koshy


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

Branch: refs/heads/trunk
Commit: 9b57fe448f01b1b6f844908adf05dd26e174db48
Parents: af50619
Author: Todd Palino <tpalino@linkedin.com>
Authored: Tue May 12 13:39:42 2015 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Tue May 12 13:39:42 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/network/SocketServer.scala | 2 +-
 core/src/main/scala/kafka/utils/ZkUtils.scala        | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/9b57fe44/core/src/main/scala/kafka/network/SocketServer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
index b9bedde..edf6214 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -384,7 +384,7 @@ private[kafka] class Processor(val id: Int,
               throw new IllegalStateException("Unrecognized key state for processor thread.")
           } catch {
             case e: EOFException => {
-              info("Closing socket connection to %s.".format(channelFor(key).socket.getInetAddress))
+              debug("Closing socket connection to %s.".format(channelFor(key).socket.getInetAddress))
               close(key)
             } case e: InvalidRequestException => {
               info("Closing socket connection to %s due to invalid request: %s".format(channelFor(key).socket.getInetAddress,
e.getMessage))

http://git-wip-us.apache.org/repos/asf/kafka/blob/9b57fe44/core/src/main/scala/kafka/utils/ZkUtils.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/utils/ZkUtils.scala b/core/src/main/scala/kafka/utils/ZkUtils.scala
index 1da8f90..2618dd3 100644
--- a/core/src/main/scala/kafka/utils/ZkUtils.scala
+++ b/core/src/main/scala/kafka/utils/ZkUtils.scala
@@ -656,7 +656,7 @@ object ZkUtils extends Logging {
         val jsonData = getPartitionReassignmentZkData(partitionsToBeReassigned)
         try {
           updatePersistentPath(zkClient, zkPath, jsonData)
-          info("Updated partition reassignment path with %s".format(jsonData))
+          debug("Updated partition reassignment path with %s".format(jsonData))
         } catch {
           case nne: ZkNoNodeException =>
             ZkUtils.createPersistentPath(zkClient, zkPath, jsonData)


Mime
View raw message