[camel-kamelets] 01/04: Elasticsearch Kamelets: Moving from Camel-Elasticsearch-Rest to Camel-Elastichsearch - Index Kamelet

[ac...@apache.org]

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

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

commit de4308f12513e16466ba6fb4bf7b842995f35611
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Jan 10 18:49:39 2023 +0100

    Elasticsearch Kamelets: Moving from Camel-Elasticsearch-Rest to Camel-Elastichsearch - Index Kamelet
    
    Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
 kamelets/elasticsearch-index-sink.kamelet.yaml | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

diff --git a/kamelets/elasticsearch-index-sink.kamelet.yaml b/kamelets/elasticsearch-index-sink.kamelet.yaml
index f3ccb39f..58d195cb 100644
--- a/kamelets/elasticsearch-index-sink.kamelet.yaml
+++ b/kamelets/elasticsearch-index-sink.kamelet.yaml
@@ -34,6 +34,8 @@ spec:
 
       The input data must be formatted in JSON according to the requirements of the index. 
 
+      If you specify the `certificate` property, you must base64 encode it before you pass it as a parameter.
+      
       In the header, you can set the following properties:
 
       - `indexId` / `ce-indexid`: The index ID for ElasticSearch.
@@ -82,22 +84,27 @@ spec:
         description: The name of the ElasticSearch index.
         type: string
         example: data
+      certificate:
+        title: Certificate 
+        description: The Certificate for accessing the Elasticsearch cluster. You must encode this value in base64.
+        type: string
+        example: data
   types:
     out:
-      mediaType: application/json
+      mediaType: text/plain
     in:
       mediaType: application/json
   dependencies:
     - "camel:core"
     - "camel:jackson"
     - "camel:kamelet"
-    - "camel:elasticsearch-rest"
+    - "camel:elasticsearch"
     - "camel:gson"
     - "camel:bean"
   template:
     beans:
       - name: local-es
-        type: "#class:org.apache.camel.component.elasticsearch.ElasticsearchComponent"
+        type: "#class:org.apache.camel.component.es.ElasticsearchComponent"
         properties:
             user: "{{?user}}"
             password: "{{?password}}"
@@ -128,6 +135,8 @@ spec:
             - set-header:
                 name: "indexName"
                 simple: "${header[ce-indexname]}"
+      - unmarshal:
+          json: {}
       - to:
           uri: "{{local-es}}:{{clusterName}}"
           parameters:
@@ -135,5 +144,4 @@ spec:
             hostAddresses: "{{hostAddresses}}"
             enableSSL: "{{enableSSL}}"
             indexName: "{{?indexName}}"
-      - marshal:
-          json: { }
+            certificatePath: "base64:{{?certificatePath}}"