[kafka] branch trunk updated: MINOR: fix typo in trace log (#12431)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 6f6c62315d7 MINOR: fix typo in trace log (#12431)
6f6c62315d7 is described below

commit 6f6c62315d7d255769a877f5834921655ca7f46b
Author: nicolasguyomar <ni...@gmail.com>
AuthorDate: Thu Dec 29 00:14:07 2022 +0100

    MINOR: fix typo in trace log (#12431)
    
    Reviewers: @Kvicii, Matthias J. Sax <ma...@confluent.io>
---
 core/src/main/scala/kafka/server/ReplicaFetcherThread.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
index fdaef89cf44..d96d9136924 100644
--- a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
@@ -126,7 +126,7 @@ class ReplicaFetcherThread(name: String,
         topicPartition, fetchOffset, log.logEndOffset))
 
     if (logTrace)
-      trace("Follower has replica log end offset %d for partition %s. Received %d messages and leader hw %d"
+      trace("Follower has replica log end offset %d for partition %s. Received %d bytes of messages and leader hw %d"
         .format(log.logEndOffset, topicPartition, records.sizeInBytes, partitionData.highWatermark))
 
     // Append the leader's messages to the log