kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject kafka git commit: KAFKA-2293; Fix incorrect format specification in Partition.scala; reviewed by Joel Koshy
Date Mon, 22 Jun 2015 22:28:46 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 1eac3ceaf -> 2270a7537


KAFKA-2293; Fix incorrect format specification in Partition.scala; reviewed by Joel Koshy


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

Branch: refs/heads/trunk
Commit: 2270a7537f7734ec02b2391fae280624520a664d
Parents: 1eac3ce
Author: Aditya Auradkar <aauradkar@linkedin.com>
Authored: Mon Jun 22 15:28:35 2015 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Mon Jun 22 15:28:35 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/cluster/Partition.scala | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/2270a753/core/src/main/scala/kafka/cluster/Partition.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/cluster/Partition.scala b/core/src/main/scala/kafka/cluster/Partition.scala
index 6cb6477..0990938 100755
--- a/core/src/main/scala/kafka/cluster/Partition.scala
+++ b/core/src/main/scala/kafka/cluster/Partition.scala
@@ -249,13 +249,12 @@ class Partition(val topic: String,
                   TopicAndPartition(topic, partitionId)))
       case None =>
         throw new NotAssignedReplicaException(("Leader %d failed to record follower %d's
position %d since the replica" +
-          " is not recognized to be one of the assigned replicas %s for partition [%s,%d]")
+          " is not recognized to be one of the assigned replicas %s for partition %s.")
           .format(localBrokerId,
                   replicaId,
-                  logReadResult.info.fetchOffsetMetadata,
+                  logReadResult.info.fetchOffsetMetadata.messageOffset,
                   assignedReplicas().map(_.brokerId).mkString(","),
-                  topic,
-                  partitionId))
+                  TopicAndPartition(topic, partitionId)))
     }
   }
 


Mime
View raw message