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"