You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/07/19 06:14:33 UTC
[camel-kamelets] 02/03: Kafka Source/Sink Kamelets: Changing the
parameters name for bootstrap server and user
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-fix
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7ea4dab63427ac82fc53b35da79aa060f6b6883c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jul 19 08:05:26 2021 +0200
Kafka Source/Sink Kamelets: Changing the parameters name for bootstrap server and user
---
.../src/main/resources/kamelets/kafka-sink.kamelet.yaml | 12 ++++++------
.../src/main/resources/kamelets/kafka-source.kamelet.yaml | 12 ++++++------
2 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
index 11a706d..9be0fda 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-sink.kamelet.yaml
@@ -25,8 +25,8 @@ spec:
Both the headers are optional.
required:
- topic
- - brokers
- - username
+ - bootstrapServers
+ - user
- password
type: object
properties:
@@ -34,7 +34,7 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- brokers:
+ bootstrapServers:
title: Brokers
description: Comma separated list of Kafka Broker URLs
type: string
@@ -48,7 +48,7 @@ spec:
description: The Simple Authentication and Security Layer (SASL) Mechanism used.
type: string
default: PLAIN
- username:
+ user:
title: Username
description: Username to authenticate to Kafka
type: string
@@ -93,7 +93,7 @@ spec:
- to:
uri: "kafka:{{topic}}"
parameters:
- brokers: "{{brokers}}"
+ brokers: "{{bootstrapServers}}"
securityProtocol: "{{securityProtocol}}"
saslMechanism: "{{saslMechanism}}"
- saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{username}}' password='{{password}}';"
+ saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{user}}' password='{{password}}';"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
index af65df6..b219149 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-source.kamelet.yaml
@@ -17,8 +17,8 @@ spec:
Receive data from Kafka topics.
required:
- topic
- - brokers
- - username
+ - bootstrapServers
+ - user
- password
type: object
properties:
@@ -26,7 +26,7 @@ spec:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- brokers:
+ bootstrapServers:
title: Brokers
description: Comma separated list of Kafka Broker URLs
type: string
@@ -40,7 +40,7 @@ spec:
description: The Simple Authentication and Security Layer (SASL) Mechanism used.
type: string
default: PLAIN
- username:
+ user:
title: Username
description: Username to authenticate to Kafka
type: string
@@ -82,10 +82,10 @@ spec:
from:
uri: "kafka:{{topic}}"
parameters:
- brokers: "{{brokers}}"
+ brokers: "{{?bootstrapServers}}"
securityProtocol: "{{securityProtocol}}"
saslMechanism: "{{saslMechanism}}"
- saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{username}}' password='{{password}}';"
+ saslJaasConfig: "org.apache.kafka.common.security.plain.PlainLoginModule required username='{{user}}' password='{{password}}';"
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"