kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joest...@apache.org
Subject kafka git commit: KAFKA-1891 MirrorMaker hides consumer exception - making troubleshooting challenging patch by Gwen Shapira reviewed by Joe Stein
Date Fri, 23 Jan 2015 03:29:38 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk a0852d477 -> 54e53b731


KAFKA-1891 MirrorMaker hides consumer exception - making troubleshooting challenging patch
by Gwen Shapira reviewed by Joe Stein


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/54e53b73
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/54e53b73
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/54e53b73

Branch: refs/heads/trunk
Commit: 54e53b7312274a3599229a36caa35f0cd931e341
Parents: a0852d4
Author: Joe Stein <joe.stein@stealth.ly>
Authored: Thu Jan 22 22:29:33 2015 -0500
Committer: Joe Stein <joe.stein@stealth.ly>
Committed: Thu Jan 22 22:29:33 2015 -0500

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/MirrorMaker.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/54e53b73/core/src/main/scala/kafka/tools/MirrorMaker.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/MirrorMaker.scala b/core/src/main/scala/kafka/tools/MirrorMaker.scala
index 5cbc810..a11dbc8 100644
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -273,7 +273,7 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
       streams = connector.createMessageStreamsByFilter(filterSpec, numStreams, new DefaultDecoder(),
new DefaultDecoder())
     } catch {
       case t: Throwable =>
-        fatal("Unable to create stream - shutting down mirror maker.")
+        fatal("Unable to create stream - shutting down mirror maker.", t)
         connector.shutdown()
     }
     consumerThreads = streams.zipWithIndex.map(streamAndIndex => new ConsumerThread(streamAndIndex._1,
mirrorDataChannel, streamAndIndex._2))


Mime
View raw message