Repository: kafka Updated Branches: refs/heads/0.10.1 472b3a558 -> 2a059fa68
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 (cherry picked from commit 7c6d70655a7de6a3b688a3e869a091f863de2eef) Signed-off-by: Jason Gustafson <ja...@confluent.io> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2a059fa6 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2a059fa6 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2a059fa6 Branch: refs/heads/0.10.1 Commit: 2a059fa6882998972f2fe8d21411582c6d999c63 Parents: 472b3a5 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:39:25 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/2a059fa6/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 {
