[camel-kafka-connector] 05/18: Use the errorHandler variable coming from Builder

[acosentino]

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 <anco...@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());