kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [05/40] git commit: Minor logging fix
Date Thu, 11 Jul 2013 06:37:15 GMT
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 <nehanarkhede@apache.org>
Authored: Wed May 22 10:29:45 2013 -0700
Committer: Neha Narkhede <nehanarkhede@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,


Mime
View raw message