kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [22/28] git commit: Minor log4j fix in the producer
Date Sat, 26 Jan 2013 06:04:36 GMT
Minor log4j fix in the producer


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8e7effc0
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8e7effc0
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8e7effc0

Branch: refs/heads/trunk
Commit: 8e7effc0550f57064fba0c3b48a248ad9c3ab003
Parents: cb3359f
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Thu Jan 24 10:06:32 2013 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Thu Jan 24 10:06:32 2013 -0800

----------------------------------------------------------------------
 .../kafka/producer/async/DefaultEventHandler.scala |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8e7effc0/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
index 05e7c6c..374cd6b 100644
--- a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
+++ b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
@@ -239,10 +239,10 @@ class DefaultEventHandler[K,V](config: ProducerConfig,
       try {
         val syncProducer = producerPool.getProducer(brokerId)
         debug("Producer sending messages with correlation id %d for topics %s to broker %d
on %s:%d"
-          .format(currentCorrelationId, messagesPerTopic, brokerId, syncProducer.config.host,
syncProducer.config.port))
+          .format(currentCorrelationId, messagesPerTopic.keySet.mkString(","), brokerId,
syncProducer.config.host, syncProducer.config.port))
         val response = syncProducer.send(producerRequest)
         debug("Producer sent messages with correlation id %d for topics %s to broker %d on
%s:%d"
-          .format(currentCorrelationId, messagesPerTopic, brokerId, syncProducer.config.host,
syncProducer.config.port))
+          .format(currentCorrelationId, messagesPerTopic.keySet.mkString(","), brokerId,
syncProducer.config.host, syncProducer.config.port))
         if (response.status.size != producerRequest.data.size)
           throw new KafkaException("Incomplete response (%s) for producer request (%s)"
             .format(response, producerRequest))


Mime
View raw message