Minor logging fix
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e93937c8 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e93937c8 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e93937c8 Branch: refs/heads/trunk Commit: e93937c88639146657f314bfdd29b200c054cade Parents: 2d40ca3 Author: Neha Narkhede <nehanarkh...@apache.org> Authored: Wed May 22 10:29:45 2013 -0700 Committer: Neha Narkhede <nehanarkh...@apache.org> Committed: Wed May 22 10:29:45 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/api/TopicMetadata.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/e93937c8/core/src/main/scala/kafka/api/TopicMetadata.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/api/TopicMetadata.scala b/core/src/main/scala/kafka/api/TopicMetadata.scala index c7f7c70..0513a59 100644 --- a/core/src/main/scala/kafka/api/TopicMetadata.scala +++ b/core/src/main/scala/kafka/api/TopicMetadata.scala @@ -64,12 +64,12 @@ case class TopicMetadata(topic: String, partitionsMetadata: Seq[PartitionMetadat partitionsMetadata.foreach { partitionMetadata => partitionMetadata.errorCode match { case ErrorMapping.NoError => - topicMetadataInfo.append("\nMetadata for partition [%s,%d] is %d".format(topic, + topicMetadataInfo.append("\nMetadata for partition [%s,%d] is %s".format(topic, partitionMetadata.partitionId, partitionMetadata.toString())) case ErrorMapping.ReplicaNotAvailableCode => // this error message means some replica other than the leader is not available. The consumer // doesn't care about non leader replicas, so ignore this - topicMetadataInfo.append("\nMetadata for partition [%s,%d] is %d".format(topic, + topicMetadataInfo.append("\nMetadata for partition [%s,%d] is %s".format(topic, partitionMetadata.partitionId, partitionMetadata.toString())) case _ => topicMetadataInfo.append("\nMetadata for partition [%s,%d] is not available due to %s".format(topic,
