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 2021/11/23 14:05:03 UTC

[camel-kamelets] 01/03: Do not use kamelet-reify anymore - Elasticsearch Index Sink Kamelet

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

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit a5a5a315eddcbff6ed49ef313259106fc7630f41
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Nov 23 14:59:39 2021 +0100

    Do not use kamelet-reify anymore - Elasticsearch Index Sink Kamelet
---
 elasticsearch-index-sink.kamelet.yaml | 15 ++++-----------
 1 file changed, 4 insertions(+), 11 deletions(-)

diff --git a/elasticsearch-index-sink.kamelet.yaml b/elasticsearch-index-sink.kamelet.yaml
index 91fdaa6..4838398 100644
--- a/elasticsearch-index-sink.kamelet.yaml
+++ b/elasticsearch-index-sink.kamelet.yaml
@@ -11,15 +11,6 @@ metadata:
     camel.apache.org/provider: "Apache Software Foundation"
     camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiPz4KPHN2ZyBlbmFibGUtYmFja2dyb3VuZD0ibmV3IDAgMCA1NTAgMjUwIiB2aWV3Qm94PSI3Nyw4Myw0MTAsOTAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiA8cGF0aCBkPSJtMTc4IDEwMi41aDMxM3Y0MWgtMzEzeiIgZmlsbD0ibm9uZSIvPgogPGcgZW5hYmxlLWJhY2tncm91bmQ9Im5ldyI+CiAgPHBhdGggZD0ibTE5My4zIDEzOS40Yy00IDAtNy4yLTEuMi05LjUtMy41cy0zLjQtNS42LTMuNC05LjdjMC00LjIgMS4xLTcuNiAzLjItMTBzNS0zLjYgOC43LTMuNmMzLjQgMCA2Lj [...]
 spec:
-  sources:
-    - content: |-
-        public class ESWorkaround extends org.apache.camel.builder.RouteBuilder {
-          @Override
-          public void configure() throws Exception {
-            getContext().setAutowiredEnabled(false);
-          }
-        }
-      name: ESWorkaround.java
   definition:
     title: "ElasticSearch Index Sink"
     description: |-
@@ -83,11 +74,13 @@ spec:
   dependencies:
     - "camel:jackson"
     - "camel:kamelet"
-    - "mvn:org.apache.camel.k:camel-k-kamelet-reify"
     - "camel:elasticsearch-rest"
     - "camel:gson"
     - "camel:bean"
   flow:
+    beans:
+      - name: local-es
+        type: "#class:org.apache.camel.component.elasticsearch.ElasticsearchComponent"
     from:
       uri: kamelet:source
       steps:
@@ -121,7 +114,7 @@ spec:
                 name: "indexName"
                 simple: "${header[ce-indexname]}"
       - to:
-          uri: "kamelet-reify:elasticsearch-rest:{{clusterName}}"
+          uri: "{{local-es}}:{{clusterName}}"
           parameters:
             operation: "INDEX"
             hostAddresses: "{{hostAddresses}}"