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/02/27 01:44:56 UTC
git commit: KAFKA-775 Very long error message on the producer during
produce requests failures; skipped review since patch is minor log4j change
Updated Branches:
refs/heads/0.8 6989dac88 -> 4f752cab1
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/0.8
Commit: 4f752cab189878053c4eb2dd78515bbf94026f3e
Parents: 6989dac
Author: Neha Narkhede <ne...@gmail.com>
Authored: Tue Feb 26 16:44:46 2013 -0800
Committer: Neha Narkhede <ne...@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)
}