From e95455bc0b89837002c00622120011a697f5067e Mon Sep 17 00:00:00 2001 From: Abhishek Sharma Date: Mon, 8 Sep 2014 11:35:05 +0530 Subject: [PATCH] Jira-1591 - Change stack trace to exception to string. for WARN log entries 'Failed to send producer request with correlation id XX to broker YY with data for partitions'. --- .../kafka/producer/async/DefaultEventHandler.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala index d8ac915..305f396 100644 --- a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala +++ b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala @@ -281,8 +281,8 @@ class DefaultEventHandler[K,V](config: ProducerConfig, } } catch { case t: Throwable => - warn("Failed to send producer request with correlation id %d to broker %d with data for partitions %s" - .format(currentCorrelationId, brokerId, messagesPerTopic.map(_._1).mkString(",")), t) + warn("Failed to send producer request with correlation id %d to broker %d with data for partitions %s. Possible cause : %s" + .format(currentCorrelationId, brokerId, messagesPerTopic.map(_._1).mkString(","), t.toString())) messagesPerTopic.keys.toSeq } } else { -- 1.7.9.5