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 {

Reply via email to