Repository: kafka Updated Branches: refs/heads/trunk f6d369b70 -> 356544cab
KAFKA-2624; Change log message position Log warning message before truncating log in order to display right offset value for the truncated log. Author: Francois Visconte <f.visco...@criteo.com> Reviewers: Dong Lin <lindon...@gmail.com>, Jun Rao <jun...@gmail.com> Closes #287 from dopuskh3/KAFKA-2624 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/356544ca Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/356544ca Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/356544ca Branch: refs/heads/trunk Commit: 356544caba6448c6ba3bcdb38bea787e1fbc277b Parents: f6d369b Author: Francois Visconte <f.visco...@criteo.com> Authored: Sat Nov 14 09:25:57 2015 -0800 Committer: Jun Rao <jun...@gmail.com> Committed: Sat Nov 14 09:25:57 2015 -0800 ---------------------------------------------------------------------- core/src/main/scala/kafka/server/ReplicaFetcherThread.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/356544ca/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 745ea2e..aa8e14f 100644 --- a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala +++ b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala @@ -167,9 +167,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 { /**
