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:28 UTC

[camel-kamelets] 01/01: Elasticsearch index sink indexId random generator for null

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]}"