Skip to content

Commit

Permalink
Regen for commit b6bafb3
Browse files Browse the repository at this point in the history
Signed-off-by: GitHub <noreply@github.com>
  • Loading branch information
nicolaferraro committed May 13, 2021
1 parent b6bafb3 commit daeda2f
Showing 1 changed file with 17 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,9 +29,10 @@ spec:
If the *indexId* parameter is not set and the source of the kamelet binding is a Kafka broker, it will take the kafka topic, partition and offset of the
element to generate an automatic ID that warrantees that this element is processed only once.
If the *indexName* parameter is not set and the source of the kamelet binding is a Kafka broker, it will take the kafka topic as the indexName.
required:
- clusterName
- indexName
- hostAddresses
type: object
properties:
Expand Down Expand Up @@ -60,6 +61,7 @@ spec:
description: The name of the index to act against.
type: string
example: data
default: 'NONE'
clusterName:
title: ElasticSearch Cluster Name
description: Name of the cluster.
Expand All @@ -69,7 +71,7 @@ spec:
title: Index ID
description: None
type: string
default: "NONE"
default: 'NONE'
types:
out:
mediaType: application/json
Expand Down Expand Up @@ -97,14 +99,18 @@ spec:
- set-header:
name: "indexId"
simple: "{{indexId}}"
- to:
uri: "kamelet-reify:elasticsearch-rest:{{clusterName}}"
parameters:
operation: "INDEX"
indexName: "{{indexName}}"
hostAddresses: "{{hostAddresses}}"
enableSSL: "{{enableSSL}}"
user: "{{user}}"
password: "{{password}}"
- choice:
when:
- simple: "'{{indexName}}' == 'NONE'"
steps:
- set-property:
name: esIndexName
simple: "${header[kafka.TOPIC]}"
otherwise:
steps:
- set-property:
name: esIndexName
simple: "{{indexName}}"
- to-d: "kamelet-reify:elasticsearch-rest:{{clusterName}}?hostAddresses=RAW({{hostAddresses}})&operation=INDEX&indexName=${exchangeProperty.esIndexName}&enableSSL={{enableSSL}}&user={{user}}&password={{password}}"
- marshal:
json: { }

0 comments on commit daeda2f

Please sign in to comment.