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/12/09 17:39:27 UTC

[camel-kamelets] branch es-index-id-fix created (now 9b54b23)

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

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


      at 9b54b23  Elasticsearch index sink indexId random generator for null

This branch includes the following new commits:

     new 9b54b23  Elasticsearch index sink indexId random generator for null

The 1 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] 01/01: Elasticsearch index sink indexId random generator for null

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

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

commit 9b54b23e2d8b402469bce753506a61e04b239cdc
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Dec 9 18:38:13 2021 +0100

    Elasticsearch index sink indexId random generator for null
---
 kamelets/elasticsearch-index-sink.kamelet.yaml                         | 3 ++-
 .../src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml  | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/kamelets/elasticsearch-index-sink.kamelet.yaml b/kamelets/elasticsearch-index-sink.kamelet.yaml
index 569fe33..97b4d59 100644
--- a/kamelets/elasticsearch-index-sink.kamelet.yaml
+++ b/kamelets/elasticsearch-index-sink.kamelet.yaml
@@ -116,7 +116,8 @@ spec:
             steps:
             - set-header:
                 name: "indexId"
-                simple: "camel-k-index-es"
+                expression:
+                  simple: ${bean:org.apache.camel.support.ShortUuidGenerator?method=generateUuid}
       - choice:
           when:
           - simple: "${header[indexName]}"
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 569fe33..97b4d59 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
@@ -116,7 +116,8 @@ spec:
             steps:
             - set-header:
                 name: "indexId"
-                simple: "camel-k-index-es"
+                expression:
+                  simple: ${bean:org.apache.camel.support.ShortUuidGenerator?method=generateUuid}
       - choice:
           when:
           - simple: "${header[indexName]}"