root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun

This commit is contained in:
Neha Narkhede 2013-04-29 17:04:42 -07:00
parent a61e738138
commit 103aef8ca3
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
View File

@ -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"