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/07/14 14:59:41 UTC
[camel-kamelets] 03/06: ElasticSearch Index Sink: Fixed
user/password as optional and fixed the headers settings
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch es-sink-index
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 034d0dbdb7b3ea27c001485300dc278038a87616
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jul 14 16:55:32 2021 +0200
ElasticSearch Index Sink: Fixed user/password as optional and fixed the headers settings
---
docs/modules/ROOT/pages/elasticsearch-index-sink.adoc | 9 +++++----
docs/modules/ROOT/pages/infinispan-source.adoc | 7 +++++--
2 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc b/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
index 8597c30..b95e3ed 100644
--- a/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
+++ b/docs/modules/ROOT/pages/elasticsearch-index-sink.adoc
@@ -9,12 +9,13 @@ This sink stores documents into ElasticSearch.
Input data must have JSON format according to the index used.
-If the *indexId* parameter is set, that value will be used as the document ID on ElasticSearch.
+- `indexId` / `ce-indexId`: as the index ID for Elasticsearch
-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 header won't be set the exchange ID will be used as index.
-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.
+- `indexName` / `ce-indexName`: as the index Name for Elasticsearch
+
+If the header won't be set the exchange ID will be used as index name.
== Configuration Options
diff --git a/docs/modules/ROOT/pages/infinispan-source.adoc b/docs/modules/ROOT/pages/infinispan-source.adoc
index 101cd7e..98e13c8 100644
--- a/docs/modules/ROOT/pages/infinispan-source.adoc
+++ b/docs/modules/ROOT/pages/infinispan-source.adoc
@@ -13,6 +13,7 @@ The following table summarizes the configuration options available for the `infi
[width="100%",cols="2,^2,3,^2,^2,^3",options="header"]
|===
| Property| Name| Description| Type| Default| Example
+| *cacheName {empty}* *| Cache Name| The name of the Infinispan cache to use| String| |
| *hosts {empty}* *| Hosts| Specifies the host of the cache on Infinispan instance| String| |
| *password {empty}* *| Password| Password to connect to Infinispan.| string| |
| *username {empty}* *| Username| Username to connect to Infinispan.| string| |
@@ -47,6 +48,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: infinispan-source
properties:
+ cacheName: "The Cache Name"
hosts: "The Hosts"
password: "The Password"
username: "The Username"
@@ -75,7 +77,7 @@ The procedure described above can be simplified into a single execution of the `
[source,shell]
----
-kamel bind infinispan-source -p "source.hosts=The Hosts" -p "source.password=The Password" -p "source.username=The Username" channel/mychannel
+kamel bind infinispan-source -p "source.cacheName=The Cache Name" -p "source.hosts=The Hosts" -p "source.password=The Password" -p "source.username=The Username" channel/mychannel
----
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.
@@ -98,6 +100,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: infinispan-source
properties:
+ cacheName: "The Cache Name"
hosts: "The Hosts"
password: "The Password"
username: "The Username"
@@ -127,7 +130,7 @@ The procedure described above can be simplified into a single execution of the `
[source,shell]
----
-kamel bind infinispan-source -p "source.hosts=The Hosts" -p "source.password=The Password" -p "source.username=The Username" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
+kamel bind infinispan-source -p "source.cacheName=The Cache Name" -p "source.hosts=The Hosts" -p "source.password=The Password" -p "source.username=The Username" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
----
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.