You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/08/12 22:24:06 UTC
kafka git commit: KAFKA-3997; log partition name on truncation
Repository: kafka
Updated Branches:
refs/heads/trunk b18c3f5ca -> fc55f804e
KAFKA-3997; log partition name on truncation
Author: Alexey Ozeritsky <ao...@yandex-team.ru>
Reviewers: Ismael Juma <is...@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 <ao...@yandex-team.ru>
Authored: Fri Aug 12 23:02:49 2016 +0100
Committer: Ismael Juma <is...@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)