[camel-kafka-connector] 01/01: In case of Sink we need to use toD instead of to

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch toD-apply
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit d6ef7e0ec0feba07635587d21b38046af379073f
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Jun 1 15:48:42 2020 +0200

    In case of Sink we need to use toD instead of to
---
 .../java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java    | 2 +-
 1 file changed, 1 insertion(+), 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);
             }
         });
     }