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

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


The following commit(s) were added to refs/heads/main by this push:
     new 0cb57a6  Regen for commit f38bdfd8c5aed5b366d5ce3414d057154cd4ed8f
0cb57a6 is described below

commit 0cb57a6e39b725af335634f9b9777b2b519ae496
Author: oscerd <osc...@users.noreply.github.com>
AuthorDate: Mon May 3 15:09:11 2021 +0000

    Regen for commit f38bdfd8c5aed5b366d5ce3414d057154cd4ed8f
    
    Signed-off-by: GitHub <nore...@github.com>
---
 .../resources/kamelets/kafka-source.kamelet.yaml   | 26 ++++++++++++++++++++++
 1 file changed, 26 insertions(+)

diff --git 
a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
 
b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
index ec84617..bf8e18b 100644
--- 
a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
+++ 
b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-source.kamelet.yaml
@@ -15,6 +15,8 @@ spec:
     required:
       - topic
       - brokers
+      - username
+      - password
     type: object
     properties:
       topic:
@@ -25,10 +27,34 @@ spec:
         title: Brokers
         description: Comma separated list of Kafka Broker URLs
         type: string
+      securityProtocol:
+        title: Security Protocol
+        description: Protocol used to communicate with brokers. 
SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
+        type: string
+        default: SASL_SSL
+      saslMechanism:
+        title: SASL Mechanism
+        description: The Simple Authentication and Security Layer (SASL) 
Mechanism used. 
+        type: string
+        default: PLAIN
+      username:
+        title: Username
+        description: Username to authenticate to Kafka 
+        type: string
+      password:
+        title: Password
+        description: Password to authenticate to kafka
+        type: string
+        format: password
+        x-descriptors:
+        - urn:alm:descriptor:com.tectonic.ui:password
   flow:
     from:
       uri: "kafka:{{topic}}"
       parameters:
         brokers: "{{brokers}}"
+        securityProtocol: "{{securityProtocol}}"
+        saslMechanism: "{{saslMechanism}}"
+        saslJaasConfig: 
"org.apache.kafka.common.security.plain.PlainLoginModule required 
username='{{username}}' password='{{password}}';"
       steps:
       - to: "kamelet:sink"

Reply via email to