kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [32/37] git commit: KAFKA-775 Very long error message on the producer during produce requests failures; skipped review since patch is minor log4j change
Date Mon, 04 Mar 2013 04:22:00 GMT
KAFKA-775 Very long error message on the producer during produce requests failures; skipped
review since patch is minor log4j change


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

Branch: refs/heads/trunk
Commit: 4f752cab189878053c4eb2dd78515bbf94026f3e
Parents: 6989dac
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Tue Feb 26 16:44:46 2013 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Tue Feb 26 16:44:46 2013 -0800

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/4f752cab/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 4cfe2a4..dab1b9c 100644
--- a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
+++ b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
@@ -82,7 +82,8 @@ class DefaultEventHandler[K,V](config: ProducerConfig,
       if(outstandingProduceRequests.size > 0) {
         producerStats.failedSendRate.mark()
         val correlationIdEnd = correlationId.get()
-        error("Failed to send requests for topics %s with correlation ids in [%d,%d]".format(outstandingProduceRequests.map(_.topic).mkString(","),
+        error("Failed to send requests for topics %s with correlation ids in [%d,%d]"
+          .format(outstandingProduceRequests.map(_.topic).toSet.mkString(","),
           correlationIdStart, correlationIdEnd-1))
         throw new FailedToSendMessageException("Failed to send messages after " + config.messageSendMaxRetries
+ " tries.", null)
       }


Mime
View raw message