From 481a41e26433416c7ebfa3a3fd6fcd4bdabd3666 Mon Sep 17 00:00:00 2001 From: Jaikiran Pai Date: Wed, 27 May 2015 09:02:15 +0530 Subject: [PATCH] Log the real exception which triggered a reconnect --- core/src/main/scala/kafka/consumer/SimpleConsumer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala index 31a2639..4cc8b79 100644 --- a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala +++ b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala @@ -76,7 +76,7 @@ class SimpleConsumer(val host: String, case e : ClosedByInterruptException => throw e case e : Throwable => - info("Reconnect due to socket error: %s".format(e.toString)) + info("Reconnect due to error:", e) // retry once try { reconnect() -- 1.9.1