Index: core/src/main/scala/kafka/consumer/SimpleConsumer.scala =================================================================== --- core/src/main/scala/kafka/consumer/SimpleConsumer.scala (revision 1225575) +++ core/src/main/scala/kafka/consumer/SimpleConsumer.scala (working copy) @@ -85,7 +85,7 @@ response = getResponse } catch { case e : java.io.IOException => - info("fetch reconnect due to " + e) + info("fetch reconnect due to ", e) // retry once try { channel = connect @@ -119,7 +119,7 @@ response = getResponse } catch { case e : java.io.IOException => - info("multifetch reconnect due to " + e) + info("multifetch reconnect due to ", e) // retry once try { channel = connect @@ -155,7 +155,7 @@ response = getResponse } catch { case e : java.io.IOException => - info("getOffsetsBefore reconnect due to " + e) + info("getOffsetsBefore reconnect due to ", e) // retry once try { channel = connect