You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/11/24 08:19:27 UTC
[camel-kafka-connector] 05/18: Use the errorHandler variable coming
from Builder
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 922a823280b7a01ff983c2c6af74682c1e0fa864
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Nov 18 07:44:32 2020 +0100
Use the errorHandler variable coming from Builder
---
.../org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 4954ed9..acc97ca 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -182,8 +182,7 @@ public class CamelKafkaConnectMain extends SimpleMain {
RouteDefinition rd = from(from);
LOG.info("Creating Camel route from({})", from);
- if (!ObjectHelper.isEmpty(props.get(CamelConnectorConfig.CAMEL_CONNECTOR_ERROR_HANDLER_CONF))) {
- String errorHandler = props.get(CamelConnectorConfig.CAMEL_CONNECTOR_ERROR_HANDLER_CONF);
+ if (!ObjectHelper.isEmpty(errorHandler)) {
switch (errorHandler) {
case "no":
rd.errorHandler(noErrorHandler());