You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/05/25 12:38:09 UTC

[08/10] camel git commit: CAMEL-11215: The breakOnError should not be default enable so we keep current behavior

CAMEL-11215: The breakOnError should not be default enable so we keep current behavior


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/303aa066
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/303aa066
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/303aa066

Branch: refs/heads/camel-2.19.x
Commit: 303aa066eab668dac049060544f883f92663933f
Parents: 957b65a
Author: Claus Ibsen <da...@apache.org>
Authored: Mon May 15 14:31:40 2017 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu May 25 14:35:51 2017 +0200

----------------------------------------------------------------------
 .../org/apache/camel/component/kafka/KafkaConfiguration.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/303aa066/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 9c288c7..ddb04a9 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -115,8 +115,8 @@ public class KafkaConfiguration implements Cloneable {
     private Boolean autoCommitEnable = true;
     @UriParam(label = "consumer", defaultValue = "sync", enums = "sync,async,none")
     private String autoCommitOnStop = "sync";
-    @UriParam(label = "consumer", defaultValue = "true")
-    private boolean breakOnFirstError = true;
+    @UriParam(label = "consumer")
+    private boolean breakOnFirstError;
     @UriParam(label = "consumer")
     private StateRepository<String, String> offsetRepository;