kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject [2/2] git commit: KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun
Date Tue, 30 Apr 2013 00:04:53 GMT
KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil
and Jun


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

Branch: refs/heads/0.8
Commit: 103aef8ca3c0eb1ff5574df656bfe5273ed9492b
Parents: a61e738
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Mon Apr 29 17:04:42 2013 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Mon Apr 29 17:04:42 2013 -0700

----------------------------------------------------------------------
 .../scala/kafka/server/ReplicaFetcherThread.scala  |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/103aef8c/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
index 74073d0..03f621a 100644
--- a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
@@ -47,11 +47,11 @@ class ReplicaFetcherThread(name:String,
 
       if (fetchOffset != replica.logEndOffset)
         throw new RuntimeException("Offset mismatch: fetched offset = %d, log end offset
= %d.".format(fetchOffset, replica.logEndOffset))
-      trace("Follower %d has replica log end offset %d. Received %d messages and leader hw
%d"
-            .format(replica.brokerId, replica.logEndOffset, messageSet.sizeInBytes, partitionData.hw))
+      trace("Follower %d has replica log end offset %d for partition %s. Received %d messages
and leader hw %d"
+            .format(replica.brokerId, replica.logEndOffset, topicAndPartition, messageSet.sizeInBytes,
partitionData.hw))
       replica.log.get.append(messageSet, assignOffsets = false)
-      trace("Follower %d has replica log end offset %d after appending %d bytes of messages"
-            .format(replica.brokerId, replica.logEndOffset, messageSet.sizeInBytes))
+      trace("Follower %d has replica log end offset %d after appending %d bytes of messages
for partition %s"
+            .format(replica.brokerId, replica.logEndOffset, messageSet.sizeInBytes, topicAndPartition))
       val followerHighWatermark = replica.logEndOffset.min(partitionData.hw)
       replica.highWatermark = followerHighWatermark
       trace("Follower %d set replica highwatermark for partition [%s,%d] to %d"


Mime
View raw message