From 08c310d39a3cd67c10a20849809866c0ef5d15ae Mon Sep 17 00:00:00 2001 From: Aditya Auradkar Date: Mon, 22 Jun 2015 10:34:44 -0700 Subject: [PATCH] Fix for 2293 --- core/src/main/scala/kafka/cluster/Partition.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/cluster/Partition.scala b/core/src/main/scala/kafka/cluster/Partition.scala index 6cb6477..cfd0ad1 100755 --- a/core/src/main/scala/kafka/cluster/Partition.scala +++ b/core/src/main/scala/kafka/cluster/Partition.scala @@ -252,7 +252,7 @@ class Partition(val topic: String, " is not recognized to be one of the assigned replicas %s for partition [%s,%d]") .format(localBrokerId, replicaId, - logReadResult.info.fetchOffsetMetadata, + logReadResult.info.fetchOffsetMetadata.messageOffset, assignedReplicas().map(_.brokerId).mkString(","), topic, partitionId)) -- 1.7.12.4