From 027eddf250897dafdb616dd491e8fd3ee832f90d Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Mon, 3 May 2021 16:35:18 +0200 Subject: [PATCH 1/5] 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 ec84617de..1248b12e3 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" From f83d6696ba3fe0e0bbe16d9a3d8c147646d61450 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Mon, 3 May 2021 16:35:52 +0200 Subject: [PATCH 2/5] Moved the kafka-source Kamelet to authenticated version --- docs/modules/ROOT/pages/kafka-source.adoc | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/docs/modules/ROOT/pages/kafka-source.adoc b/docs/modules/ROOT/pages/kafka-source.adoc index e8e229505..6e937be7b 100644 --- a/docs/modules/ROOT/pages/kafka-source.adoc +++ b/docs/modules/ROOT/pages/kafka-source.adoc @@ -12,7 +12,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| | +| *saslMechanism {empty}* *| SASL Mechanism| The Simple Authentication and Security Layer (SASL) Mechanism used.| string| `"PLAIN"`| +| *securityProtocol {empty}* *| Security Protocol| Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported| string| `"SASL_SSL"`| | *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| | +| *username {empty}* *| Username| Username to authenticate to Kafka| string| | |=== NOTE: Fields marked with ({empty}*) are mandatory. @@ -40,7 +44,9 @@ spec: name: kafka-source properties: brokers: "The Brokers" + password: "The Password" topic: "The Topic Names" + username: "The Username" sink: ref: kind: InMemoryChannel From 6b1674123aeba2f318956873451f6752fd99cfed Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Mon, 3 May 2021 16:36:29 +0200 Subject: [PATCH 3/5] Moved the kafka-source Kamelet to authenticated version --- kafka-source.kamelet.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka-source.kamelet.yaml b/kafka-source.kamelet.yaml index 1248b12e3..186b7cf2c 100644 --- a/kafka-source.kamelet.yaml +++ b/kafka-source.kamelet.yaml @@ -57,6 +57,6 @@ spec: brokers: "{{brokers}}" securityProtocol: "{{securityProtocol}}" saslMechanism: "{{saslMechanism}}" - saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{user}}' password='{{password}}';" + saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{username}}' password='{{password}}';" steps: - to: "kamelet:sink" From d5b97f3412bec2334757320606cbd3757e74dabc Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Mon, 3 May 2021 16:39:25 +0200 Subject: [PATCH 4/5] Moved the kafka-source Kamelet to authenticated version --- kafka-source.kamelet.yaml | 2 -- 1 file changed, 2 deletions(-) diff --git a/kafka-source.kamelet.yaml b/kafka-source.kamelet.yaml index 186b7cf2c..bf8e18bd7 100644 --- a/kafka-source.kamelet.yaml +++ b/kafka-source.kamelet.yaml @@ -15,8 +15,6 @@ spec: required: - topic - brokers - - securityProtocol - - saslMechanism - username - password type: object From a9a96cf63cca6fabeac8092f13f62507699e2dc7 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Mon, 3 May 2021 16:39:35 +0200 Subject: [PATCH 5/5] Moved the kafka-source Kamelet to authenticated version --- docs/modules/ROOT/pages/kafka-source.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/modules/ROOT/pages/kafka-source.adoc b/docs/modules/ROOT/pages/kafka-source.adoc index 6e937be7b..a095dd36b 100644 --- a/docs/modules/ROOT/pages/kafka-source.adoc +++ b/docs/modules/ROOT/pages/kafka-source.adoc @@ -13,10 +13,10 @@ 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| | -| *saslMechanism {empty}* *| SASL Mechanism| The Simple Authentication and Security Layer (SASL) Mechanism used.| string| `"PLAIN"`| -| *securityProtocol {empty}* *| Security Protocol| Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported| string| `"SASL_SSL"`| | *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.