Skip to content
Browse files

KAFKA-775 Very long error message on the producer during produce requ…

…ests failures; skipped review since patch is minor log4j change
  • Loading branch information...
1 parent 6989dac commit 4f752cab189878053c4eb2dd78515bbf94026f3e @nehanarkhede nehanarkhede committed Feb 26, 2013
Showing with 2 additions and 1 deletion.
  1. +2 −1 core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
View
3 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)
}

0 comments on commit 4f752ca

Please sign in to comment.
Something went wrong with that request. Please try again.