You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2013/05/22 19:30:58 UTC

git commit: Minor logging fix

Updated Branches:
  refs/heads/0.8 2d40ca30d -> e93937c88


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/0.8
Commit: e93937c88639146657f314bfdd29b200c054cade
Parents: 2d40ca3
Author: Neha Narkhede <ne...@apache.org>
Authored: Wed May 22 10:29:45 2013 -0700
Committer: Neha Narkhede <ne...@apache.org>
Committed: Wed May 22 10:29:45 2013 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/api/TopicMetadata.scala |    4 ++--
 1 files 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,