kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-3997; log partition name on truncation
Date Fri, 12 Aug 2016 22:24:06 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b18c3f5ca -> fc55f804e


KAFKA-3997; log partition name on truncation

Author: Alexey Ozeritsky <aozeritsky@yandex-team.ru>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1724 from resetius/KAFKA-3997


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fc55f804
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fc55f804
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fc55f804

Branch: refs/heads/trunk
Commit: fc55f804e1b66a5ced14841d05e03f60cce65c63
Parents: b18c3f5
Author: Alexey Ozeritsky <aozeritsky@yandex-team.ru>
Authored: Fri Aug 12 23:02:49 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Aug 12 23:02:49 2016 +0100

----------------------------------------------------------------------
 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/fc55f804/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 c6a28c6..ef602e4 100644
--- a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
@@ -175,7 +175,7 @@ class ReplicaFetcherThread(name: String,
       if (!LogConfig.fromProps(brokerConfig.originals, AdminUtils.fetchEntityConfig(replicaMgr.zkUtils,
         ConfigType.Topic, topicAndPartition.topic)).uncleanLeaderElectionEnable) {
         // Log a fatal error and shutdown the broker to ensure that data loss does not unexpectedly
occur.
-        fatal("Exiting because log truncation is not allowed for topic %s,".format(topicAndPartition.topic)
+
+        fatal("Exiting because log truncation is not allowed for partition %s,".format(topicAndPartition)
+
           " Current leader %d's latest offset %d is less than replica %d's latest offset
%d"
           .format(sourceBroker.id, leaderEndOffset, brokerConfig.brokerId, replica.logEndOffset.messageOffset))
         System.exit(1)


Mime
View raw message