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 99fef6ad6cee3fec9683191a0c030b8ce4e2bc9b Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Jan 10 18:50:12 2023 +0100 Elasticsearch Kamelets: Moving from Camel-Elasticsearch-Rest to Camel-Elastichsearch - Index Kamelet Signed-off-by: Andrea Cosentino <[email protected]> --- .../kamelets/elasticsearch-index-sink.kamelet.yaml | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 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 f3ccb39f..58d195cb 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 @@ -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}}"
