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/c17ca1f9
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c17ca1f9
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c17ca1f9

Branch: refs/heads/CAMEL-11215
Commit: c17ca1f943fb203ec7a5650c1e166541310b1cba
Parents: 178d60a
Author: Claus Ibsen <davscl...@apache.org>
Authored: Mon May 15 14:31:40 2017 +0200
Committer: Claus Ibsen <davscl...@apache.org>
Committed: Mon May 15 14:31:40 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/c17ca1f9/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;
 

Reply via email to