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/trunk Commit: 103aef8ca3c0eb1ff5574df656bfe5273ed9492b Parents: a61e738 Author: Neha Narkhede <neha.narkh...@gmail.com> Authored: Mon Apr 29 17:04:42 2013 -0700 Committer: Neha Narkhede <neha.narkh...@gmail.com> Committed: Mon Apr 29 17:04:42 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/server/ReplicaFetcherThread.scala | 8 ++++---- 1 file 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"
