[camel-kamelets] 02/05: Added Kafka Sink Kamelet

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch kafka-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit dd8cec0c7fdb50e7cc9daa7db51251291a3247c2
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 4 14:38:18 2021 +0200

    Added Kafka Sink Kamelet
---
 docs/modules/ROOT/nav.adoc                          | 1 +
 docs/modules/ROOT/pages/kafka-not-secured-sink.adoc | 6 ++++++
 kafka-sink.kamelet.yaml                             | 4 ++--
 3 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index d42452f..bea3717 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -47,6 +47,7 @@
 * xref:ROOT:jira-source.adoc[image:kamelets/jira-source.svg[] Jira Source]
 * xref:ROOT:kafka-not-secured-sink.adoc[image:kamelets/kafka-not-secured-sink.svg[] Kafka Not Secured Sink]
 * xref:ROOT:kafka-not-secured-source.adoc[image:kamelets/kafka-not-secured-source.svg[] Kafka Not Secured Source]
+* xref:ROOT:kafka-not-secured-sink.adoc[image:kamelets/kafka-not-secured-sink.svg[] Kafka Not Secured Sink]
 * xref:ROOT:kafka-source.adoc[image:kamelets/kafka-source.svg[] Kafka Source]
 * xref:ROOT:mail-imap-source.adoc[image:kamelets/mail-imap-source.svg[] Mail IMAP Source]
 * xref:ROOT:minio-sink.adoc[image:kamelets/minio-sink.svg[] Minio Sink]
diff --git a/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc b/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
index 0c07d35..ad8fb4c 100644
--- a/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
+++ b/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
@@ -20,7 +20,11 @@ The following table summarizes the configuration options available for the `kafk
 |===
 | Property| Name| Description| Type| Default| Example
 | *brokers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| | 
+| *password {empty}* *| Password| Password to authenticate to kafka| string| | 
 | *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| | 
+| *username {empty}* *| Username| Username to authenticate to Kafka| string| | 
+| saslMechanism| SASL Mechanism| The Simple Authentication and Security Layer (SASL) Mechanism used.| string| `"PLAIN"`| 
+| securityProtocol| Security Protocol| Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported| string| `"SASL_SSL"`| 
 |===
 
 NOTE: Fields marked with ({empty}*) are mandatory.
@@ -53,7 +57,9 @@ spec:
       name: kafka-not-secured-sink
     properties:
       brokers: "The Brokers"
+      password: "The Password"
       topic: "The Topic Names"
+      username: "The Username"
 
 ----
 
diff --git a/kafka-sink.kamelet.yaml b/kafka-sink.kamelet.yaml
index 42044bc..44ad970 100644
--- a/kafka-sink.kamelet.yaml
+++ b/kafka-sink.kamelet.yaml
@@ -1,7 +1,7 @@
 apiVersion: camel.apache.org/v1alpha1
 kind: Kamelet
 metadata:
-  name: kafka-not-secured-sink
+  name: kafka-sink
   annotations:
     camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0idXRmLTgiPz4NCjwhLS0gR2VuZXJhdG9yOiBBZG9iZSBJbGx1c3RyYXRvciAxOS4wLjAsIFNWRyBFeHBvcnQgUGx1Zy1JbiAuIFNWRyBWZXJzaW9uOiA2LjAwIEJ1aWxkIDApICAtLT4NCjxzdmcgdmVyc2lvbj0iMS4xIiBpZD0iTGF5ZXJfMSIgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiB4bWxuczp4bGluaz0iaHR0cDovL3d3dy53My5vcmcvMTk5OS94bGluayIgeD0iMHB4IiB5PSIwcHgiDQoJIHZpZXdCb3g9IjAgMCA1MDAgNTAwIiBzdHlsZT0iZW5hYmxlLWJhY2tncm91bmQ6bmV3IDAgMCA1MD [...]
     camel.apache.org/provider: "Apache Software Foundation"
@@ -9,7 +9,7 @@ metadata:
     camel.apache.org/kamelet.type: "sink"
 spec:
   definition:
-    title: "Kafka Not Secured Sink"
+    title: "Kafka Sink"
     description: |-
       Send data to Kafka topics.