Repository: kafka Updated Branches: refs/heads/trunk 0c8c167e8 -> 7c6d70655
KAFKA-3965; MirrorMaker should not commit offset when exception is thrown from producer.send Author: Jiangjie Qin <becket....@gmail.com> Reviewers: Manikumar Reddy <manikumar.re...@gmail.com>, Ismael Juma <ism...@juma.me.uk>, Jason Gustafson <ja...@confluent.io> Closes #1915 from becketqin/KAFKA-3965 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/7c6d7065 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/7c6d7065 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/7c6d7065 Branch: refs/heads/trunk Commit: 7c6d70655a7de6a3b688a3e869a091f863de2eef Parents: 0c8c167 Author: Jiangjie Qin <becket....@gmail.com> Authored: Thu Sep 29 16:36:42 2016 -0700 Committer: Jason Gustafson <ja...@confluent.io> Committed: Thu Sep 29 16:36:42 2016 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/tools/MirrorMaker.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/7c6d7065/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 979203c..17b8f0b 100755 --- a/core/src/main/scala/kafka/tools/MirrorMaker.scala +++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala @@ -444,6 +444,7 @@ object MirrorMaker extends Logging with KafkaMetricsGroup { } } catch { case t: Throwable => + exitingOnSendFailure = true fatal("Mirror maker thread failure due to ", t) } finally { CoreUtils.swallow {
