From 3f96c3778f2277eae2b84e7ba6aae424010b3c84 Mon Sep 17 00:00:00 2001 From: Francois Visconte Date: Thu, 8 Oct 2015 17:28:09 +0200 Subject: [PATCH] KAFKA-2624: Change log message position Log warning message before truncating log in order to display right offset value for the truncated log. --- 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 82a60018acdd3..34f56c057440d 100644 --- a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala +++ b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala @@ -153,9 +153,9 @@ class ReplicaFetcherThread(name: String, Runtime.getRuntime.halt(1) } - replicaMgr.logManager.truncateTo(Map(topicAndPartition -> leaderEndOffset)) warn("Replica %d for partition %s reset its fetch offset from %d to current leader %d's latest offset %d" .format(brokerConfig.brokerId, topicAndPartition, replica.logEndOffset.messageOffset, sourceBroker.id, leaderEndOffset)) + replicaMgr.logManager.truncateTo(Map(topicAndPartition -> leaderEndOffset)) leaderEndOffset } else { /**