From 589adea7c8fe31bb7181c9de6b924413d5da544d Mon Sep 17 00:00:00 2001 From: Sriram Subramanian Date: Thu, 24 Jan 2013 10:22:14 -0800 Subject: [PATCH] modified: core/src/main/scala/kafka/tools/KafkaMigrationTool.java --- .../main/scala/kafka/tools/KafkaMigrationTool.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/core/src/main/scala/kafka/tools/KafkaMigrationTool.java b/core/src/main/scala/kafka/tools/KafkaMigrationTool.java index 1f5c7ba..dbbddae 100644 --- a/core/src/main/scala/kafka/tools/KafkaMigrationTool.java +++ b/core/src/main/scala/kafka/tools/KafkaMigrationTool.java @@ -290,7 +290,7 @@ public class KafkaMigrationTool } logger.info(String.format("Migration thread %s finishes running", threadName)); } catch (Throwable t){ - System.out.println("Migration thread failure due to " + t); + logger.fatal("Migration thread failure due to ", t); t.printStackTrace(System.out); } } -- 1.7.1