This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch es-search in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit e4f4ebbfe40e8a84a806e658455d579f678b7344 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Jan 11 13:55:22 2023 +0100 Elasticsearch Kamelets: Moving from Camel-Elasticsearch-Rest to Camel-Elastichsearch - Search Kamelet Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../kamelets/elasticsearch-search-source.kamelet.yaml | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-search-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-search-source.kamelet.yaml index 9d853bf3..d98d2d21 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-search-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/elasticsearch-search-source.kamelet.yaml @@ -80,6 +80,10 @@ spec: title: ElasticSearch Cluster Name description: The name of the cluster. type: string + certificate: + title: Certificate + description: The Certificate for accessing the Elasticsearch cluster. You must encode this value in base64. + type: string types: out: mediaType: application/json @@ -87,12 +91,12 @@ spec: - "camel:core" - "camel:kamelet" - "camel:timer" - - "camel:elasticsearch-rest" + - "camel:elasticsearch" - "camel:gson" 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}}" @@ -102,10 +106,7 @@ spec: period: "{{period}}" steps: - set-body: - constant: "{{query}}" - - set-header: - name: "Content-Type" - constant: "text/plain" + constant: "{{query?nested=false}}" - to: uri: "{{local-es}}:{{clusterName}}" parameters: @@ -113,6 +114,7 @@ spec: indexName: "{{indexName}}" hostAddresses: "{{hostAddresses}}" enableSSL: "{{enableSSL}}" + certificatePath: "base64:{{?certificate}}" - marshal: json: library: Gson