kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1387269 - /incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala
Date Tue, 18 Sep 2012 17:18:10 GMT
Author: junrao
Date: Tue Sep 18 17:18:09 2012
New Revision: 1387269

URL: http://svn.apache.org/viewvc?rev=1387269&view=rev
Log:
trivial fix to log topics in fetching metadata properly

Modified:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala?rev=1387269&r1=1387268&r2=1387269&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala
(original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala
Tue Sep 18 17:18:09 2012
@@ -77,7 +77,7 @@ class BrokerPartitionInfo(producerConfig
     var t: Throwable = null
     while(i < brokers.size && !fetchMetaDataSucceeded) {
       val producer: SyncProducer = ProducerPool.createSyncProducer(producerConfig, brokers(i))
-      info("Fetching metadata for topic %s".format(brokers))
+      info("Fetching metadata for topic %s".format(topics))
       try {
         topicMetaDataResponse = producer.send(topicMetadataRequest)
         fetchMetaDataSucceeded = true



Mime
View raw message