Index: core/src/main/scala/kafka/utils/Utils.scala =================================================================== --- core/src/main/scala/kafka/utils/Utils.scala (revision 1226576) +++ core/src/main/scala/kafka/utils/Utils.scala (working copy) @@ -60,8 +60,7 @@ catch { case t => // log any error and the stack trace - error(t) - error(stackTrace(t), t) + error("error in loggedRunnable", t) } } } Index: core/src/main/scala/kafka/producer/SyncProducer.scala =================================================================== --- core/src/main/scala/kafka/producer/SyncProducer.scala (revision 1226576) +++ core/src/main/scala/kafka/producer/SyncProducer.scala (working copy) @@ -61,13 +61,13 @@ } catch { case e: Throwable => - trace("error iterating messages " + e + Utils.stackTrace(e)) + trace("error iterating messages ", e) } } } catch { case e: Throwable => - trace("error verifying sendbuffer " + e + Utils.stackTrace(e)) + trace("error verifying sendbuffer ", e) } } } Index: core/src/main/scala/kafka/server/KafkaServerStartable.scala =================================================================== --- core/src/main/scala/kafka/server/KafkaServerStartable.scala (revision 1226576) +++ core/src/main/scala/kafka/server/KafkaServerStartable.scala (working copy) @@ -203,8 +203,7 @@ } catch { case e => - fatal(e + Utils.stackTrace(e)) - fatal(topic + " stream " + threadId + " unexpectedly exited") + fatal(topic + " stream " + threadId + " unexpectedly exited", e) }finally { shutdownComplete.countDown info("Stopped mirroring thread %s for topic %s and stream %d".format(name, topic, threadId))