kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject svn commit: r1226549 - /incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
Date Mon, 02 Jan 2012 20:51:37 GMT
Author: jkreps
Date: Mon Jan  2 20:51:36 2012
New Revision: 1226549

URL: http://svn.apache.org/viewvc?rev=1226549&view=rev
Log:
KAFKA-229 Patch from Joe Stein. Log full exception stack trace instead of just message.


Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala?rev=1226549&r1=1226548&r2=1226549&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala Mon Jan
 2 20:51:36 2012
@@ -85,7 +85,7 @@ class SimpleConsumer(val host: String,
         response = getResponse
       } catch {
         case e : java.io.IOException =>
-          info("fetch reconnect due to " + e)
+          info("Reconnect in fetch request due to socket error: ", e)
           // retry once
           try {
             channel = connect
@@ -119,7 +119,7 @@ class SimpleConsumer(val host: String,
         response = getResponse
       } catch {
         case e : java.io.IOException =>
-          info("multifetch reconnect due to " + e)
+          info("Reconnect in multifetch due to socket error: ", e)
           // retry once
           try {
             channel = connect
@@ -155,7 +155,7 @@ class SimpleConsumer(val host: String,
         response = getResponse
       } catch {
         case e : java.io.IOException =>
-          info("getOffsetsBefore reconnect due to " + e)
+          info("Reconnect in get offetset request due to socket error: ", e)
           // retry once
           try {
             channel = connect



Mime
View raw message