You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2012/01/02 21:51:37 UTC
svn commit: r1226549 -
/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
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