This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-source-auth
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 027eddf250897dafdb616dd491e8fd3ee832f90d
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon May 3 16:35:18 2021 +0200
Moved the kafka-source Kamelet to authenticated version
---
kafka-source.kamelet.yaml | 28 ++++++++++++++++++++++++++++
1 file changed, 28 insertions(+)
diff --git a/kafka-source.kamelet.yaml b/kafka-source.kamelet.yaml
index ec84617..1248b12 100644
--- a/kafka-source.kamelet.yaml
+++ b/kafka-source.kamelet.yaml
@@ -15,6 +15,10 @@ spec:
required:
- topic
- brokers
+ - securityProtocol
+ - saslMechanism
+ - username
+ - password
type: object
properties:
topic:
@@ -25,10 +29,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='{{user}}' password='{{password}}';"
steps:
- to: "kamelet:sink"
