This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch toD in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 49b8f26c7dc19217613c52a760eb340b5dd85459 Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Jun 8 14:46:59 2020 +0200 In case of Sink we need to use toD instead of to --- .../java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java | 2 +- .../org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java index 66f46fb..45ab9a9 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java @@ -105,7 +105,7 @@ public class CamelMainSupport { } else { LOG.info("Creating Camel route from({}).to({})", fromUrl, toUrl); } - rd.to(toUrl); + rd.toD(toUrl); } }); } diff --git a/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java b/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java index eba4fb4..141772a 100644 --- a/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java +++ b/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java @@ -121,6 +121,7 @@ public class CamelSinkFileITCase extends AbstractKafkaTest { } catch (Exception e) { LOG.error("HTTP test failed: {}", e.getMessage(), e); + System.err.println(e.getMessage()); fail(e.getMessage()); } }
