[
https://issues.apache.org/jira/browse/KAFKA-775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-775:
--------------------------------
Status: Patch Available (was: In Progress)
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)
}
> Very long error message on the producer during produce requests failures
> ------------------------------------------------------------------------
>
> Key: KAFKA-775
> URL: https://issues.apache.org/jira/browse/KAFKA-775
> Project: Kafka
> Issue Type: Bug
> Components: producer
> Affects Versions: 0.8
> Reporter: Neha Narkhede
> Assignee: Neha Narkhede
> Priority: Blocker
> Labels: kafka-0.8, p1
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> Saw this on the producer during a cluster upgrade -
> 2013-02-26 23:19:37,386 - ERROR
> [ProducerSendThread-1413963846:Logging$class@96] - Failed to send requests
> for topics
> LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,LixTreatmentEvent,...
> super long line)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
