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 <[email protected]> Authored: Thu Jan 22 22:29:33 2015 -0500 Committer: Joe Stein <[email protected]> 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))
