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/07/21 13:30:16 UTC

[camel-kamelets] branch es-sink-index-fix created (now 6cd7e52)

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

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


      at 6cd7e52  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

This branch includes the following new commits:

     new c319ba3  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
     new 487b412  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
     new 3afdb12  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
     new 80c7bd4  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
     new a5d3994  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
     new 6cd7e52  Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


[camel-kamelets] 06/06: Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 6cd7e527434f9e319319da9cae73bab1bf75019f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 21 15:29:48 2021 +0200

    Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
---
 docs/modules/ROOT/pages/elasticsearch-index-sink.adoc | 1 -
 1 file changed, 1 deletion(-)

diff --git a/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc b/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
index 618ae2e..e638900 100644
--- a/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
+++ b/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
@@ -26,7 +26,6 @@ The following table summarizes the configuration options available for the `elas
 | *clusterName {empty}* *| ElasticSearch Cluster Name| Name of the cluster.| string| | `"quickstart"`
 | *hostAddresses {empty}* *| Host Addresses| Comma separated list with ip:port formatted remote transport addresses to use.| string| | `"quickstart-es-http:9200"`
 | enableSSL| Enable SSL| Do we want to connect using SSL?| boolean| `true`| 
-| indexId| Index ID| None| string| | 
 | indexName| Index in ElasticSearch| The name of the index to act against.| string| | `"data"`
 | password| Password| Password to connect to ElasticSearch.| string| | 
 | user| Username| Username to connect to ElasticSearch.| string| | 

[camel-kamelets] 03/06: Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 3afdb1278833963eb6deecc2ace5f28e6cc0d8f7
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 21 15:28:18 2021 +0200

    Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
---
 docs/modules/ROOT/pages/elasticsearch-index-sink.adoc | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc b/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
index da5977a..618ae2e 100644
--- a/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
+++ b/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
@@ -26,6 +26,8 @@ The following table summarizes the configuration options available for the `elas
 | *clusterName {empty}* *| ElasticSearch Cluster Name| Name of the cluster.| string| | `"quickstart"`
 | *hostAddresses {empty}* *| Host Addresses| Comma separated list with ip:port formatted remote transport addresses to use.| string| | `"quickstart-es-http:9200"`
 | enableSSL| Enable SSL| Do we want to connect using SSL?| boolean| `true`| 
+| indexId| Index ID| None| string| | 
+| indexName| Index in ElasticSearch| The name of the index to act against.| string| | `"data"`
 | password| Password| Password to connect to ElasticSearch.| string| | 
 | user| Username| Username to connect to ElasticSearch.| string| | 
 |===

[camel-kamelets] 04/06: Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 80c7bd4b0a57226b9420810736a6c6172594c898
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 21 15:29:16 2021 +0200

    Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
---
 elasticsearch-index-sink.kamelet.yaml | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/elasticsearch-index-sink.kamelet.yaml b/elasticsearch-index-sink.kamelet.yaml
index 7babac9..308795c 100644
--- a/elasticsearch-index-sink.kamelet.yaml
+++ b/elasticsearch-index-sink.kamelet.yaml
@@ -72,10 +72,6 @@ spec:
         description: The name of the index to act against.
         type: string
         example: data
-      indexId:
-        title: Index ID
-        description: None
-        type: string
   types:
     out:
       mediaType: application/json

[camel-kamelets] 01/06: Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit c319ba302f5702245d25b0c0c70e9af7b1bf15c8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 21 15:26:38 2021 +0200

    Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
---
 elasticsearch-index-sink.kamelet.yaml | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/elasticsearch-index-sink.kamelet.yaml b/elasticsearch-index-sink.kamelet.yaml
index 6fc368e..7babac9 100644
--- a/elasticsearch-index-sink.kamelet.yaml
+++ b/elasticsearch-index-sink.kamelet.yaml
@@ -67,6 +67,15 @@ spec:
         description: Name of the cluster.
         type: string
         example: quickstart
+      indexName:
+        title: Index in ElasticSearch
+        description: The name of the index to act against.
+        type: string
+        example: data
+      indexId:
+        title: Index ID
+        description: None
+        type: string
   types:
     out:
       mediaType: application/json
@@ -98,7 +107,7 @@ spec:
             steps:
             - set-header:
                 name: "indexId"
-                simple: "${exchangeId}"
+                simple: "camel-k-index-es"
       - choice:
           when:
           - simple: "${header[indexName]}"
@@ -111,11 +120,6 @@ spec:
             - set-header:
                 name: "indexName"
                 simple: "${header[ce-indexName]}"
-          otherwise:
-            steps:
-            - set-header:
-                name: "indexName"
-                simple: "${exchangeId}"
       - to:
           uri: "kamelet-reify:elasticsearch-rest:{{clusterName}}"
           parameters:
@@ -124,5 +128,6 @@ spec:
             enableSSL: "{{enableSSL}}"
             user: "{{?user}}"
             password: "{{?password}}"
+            indexName: "{{?indexName}}"
       - marshal:
           json: { }

[camel-kamelets] 05/06: Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit a5d399438a6953fd6b4236ea7f6481ac451c6493
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 21 15:29:34 2021 +0200

    Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
---
 .../src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
index 7babac9..308795c 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
@@ -72,10 +72,6 @@ spec:
         description: The name of the index to act against.
         type: string
         example: data
-      indexId:
-        title: Index ID
-        description: None
-        type: string
   types:
     out:
       mediaType: application/json

[camel-kamelets] 02/06: Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 487b412def46ce1e1b84b2995877c1352552a412
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 21 15:27:46 2021 +0200

    Elasticsearch index Kamelet: Fixed the indexId and indexName default to exchangeId
---
 .../kamelets/elasticsearch-index-sink.kamelet.yaml      | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
index 6fc368e..7babac9 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml
@@ -67,6 +67,15 @@ spec:
         description: Name of the cluster.
         type: string
         example: quickstart
+      indexName:
+        title: Index in ElasticSearch
+        description: The name of the index to act against.
+        type: string
+        example: data
+      indexId:
+        title: Index ID
+        description: None
+        type: string
   types:
     out:
       mediaType: application/json
@@ -98,7 +107,7 @@ spec:
             steps:
             - set-header:
                 name: "indexId"
-                simple: "${exchangeId}"
+                simple: "camel-k-index-es"
       - choice:
           when:
           - simple: "${header[indexName]}"
@@ -111,11 +120,6 @@ spec:
             - set-header:
                 name: "indexName"
                 simple: "${header[ce-indexName]}"
-          otherwise:
-            steps:
-            - set-header:
-                name: "indexName"
-                simple: "${exchangeId}"
       - to:
           uri: "kamelet-reify:elasticsearch-rest:{{clusterName}}"
           parameters:
@@ -124,5 +128,6 @@ spec:
             enableSSL: "{{enableSSL}}"
             user: "{{?user}}"
             password: "{{?password}}"
+            indexName: "{{?indexName}}"
       - marshal:
           json: { }