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:21:11 UTC
[camel-kamelets] branch main updated (bf9eb4e -> c512304)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.
from bf9eb4e Regen for commit da9dbaf6b66c31bffed50f2f560eaa9d879a02dd
new 2b3354b Kafka Source/Sink Kamelets: Changing the parameters name for bootstrap server and user
new 151ad20 Kafka Source/Sink Kamelets: Changing the parameters name for bootstrap server and user
new c512304 Kafka Source/Sink Kamelets: Changing the parameters name for bootstrap server and user
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/modules/ROOT/pages/kafka-sink.adoc | 16 ++++++++--------
docs/modules/ROOT/pages/kafka-source.adoc | 16 ++++++++--------
kafka-sink.kamelet.yaml | 12 ++++++------
kafka-source.kamelet.yaml | 12 ++++++------
.../src/main/resources/kamelets/kafka-sink.kamelet.yaml | 12 ++++++------
.../main/resources/kamelets/kafka-source.kamelet.yaml | 12 ++++++------
6 files changed, 40 insertions(+), 40 deletions(-)
[camel-kamelets] 03/03: Kafka Source/Sink Kamelets: Changing the
parameters name for bootstrap server and user
Posted by ac...@apache.org.
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
commit c512304ad13c891ef5688078789dfea82cf15690
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jul 19 08:06:01 2021 +0200
Kafka Source/Sink Kamelets: Changing the parameters name for bootstrap server and user
---
docs/modules/ROOT/pages/kafka-sink.adoc | 16 ++++++++--------
docs/modules/ROOT/pages/kafka-source.adoc | 16 ++++++++--------
2 files changed, 16 insertions(+), 16 deletions(-)
diff --git a/docs/modules/ROOT/pages/kafka-sink.adoc b/docs/modules/ROOT/pages/kafka-sink.adoc
index 6702b19..4adbd68 100644
--- a/docs/modules/ROOT/pages/kafka-sink.adoc
+++ b/docs/modules/ROOT/pages/kafka-sink.adoc
@@ -21,10 +21,10 @@ The following table summarizes the configuration options available for the `kafk
[width="100%",cols="2,^2,3,^2,^2,^3",options="header"]
|===
| Property| Name| Description| Type| Default| Example
-| *brokers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
+| *bootstrapServers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
| *password {empty}* *| Password| Password to authenticate to kafka| string| |
| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| |
-| *username {empty}* *| Username| Username to authenticate to Kafka| string| |
+| *user {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"`|
|===
@@ -58,10 +58,10 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-sink
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Brokers"
password: "The Password"
topic: "The Topic Names"
- username: "The Username"
+ user: "The Username"
----
@@ -82,7 +82,7 @@ The procedure described above can be simplified into a single execution of the `
[source,shell]
----
-kamel bind channel/mychannel kafka-sink -p "sink.brokers=The Brokers" -p "sink.password=The Password" -p "sink.topic=The Topic Names" -p "sink.username=The Username"
+kamel bind channel/mychannel kafka-sink -p "sink.bootstrapServers=The Brokers" -p "sink.password=The Password" -p "sink.topic=The Topic Names" -p "sink.user=The Username"
----
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.
@@ -110,10 +110,10 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-sink
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Brokers"
password: "The Password"
topic: "The Topic Names"
- username: "The Username"
+ user: "The Username"
----
@@ -135,7 +135,7 @@ The procedure described above can be simplified into a single execution of the `
[source,shell]
----
-kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic kafka-sink -p "sink.brokers=The Brokers" -p "sink.password=The Password" -p "sink.topic=The Topic Names" -p "sink.username=The Username"
+kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic kafka-sink -p "sink.bootstrapServers=The Brokers" -p "sink.password=The Password" -p "sink.topic=The Topic Names" -p "sink.user=The Username"
----
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.
diff --git a/docs/modules/ROOT/pages/kafka-source.adoc b/docs/modules/ROOT/pages/kafka-source.adoc
index 3ba13ca..b6c92aa 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
[width="100%",cols="2,^2,3,^2,^2,^3",options="header"]
|===
| Property| Name| Description| Type| Default| Example
-| *brokers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
+| *bootstrapServers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
| *password {empty}* *| Password| Password to authenticate to kafka| string| |
| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| |
-| *username {empty}* *| Username| Username to authenticate to Kafka| string| |
+| *user {empty}* *| Username| Username to authenticate to Kafka| string| |
| allowManualCommit| Allow Manual Commit| Whether to allow doing manual commits| boolean| `false`|
| autoCommitEnable| Auto Commit Enable| If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer| boolean| `true`|
| autoOffsetReset| Auto Offset Reset| What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none| string| `"latest"`|
@@ -49,10 +49,10 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-source
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Brokers"
password: "The Password"
topic: "The Topic Names"
- username: "The Username"
+ user: "The Username"
sink:
ref:
kind: InMemoryChannel
@@ -78,7 +78,7 @@ The procedure described above can be simplified into a single execution of the `
[source,shell]
----
-kamel bind kafka-source -p "source.brokers=The Brokers" -p "source.password=The Password" -p "source.topic=The Topic Names" -p "source.username=The Username" channel/mychannel
+kamel bind kafka-source -p "source.bootstrapServers=The Brokers" -p "source.password=The Password" -p "source.topic=The Topic Names" -p "source.user=The Username" channel/mychannel
----
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.
@@ -101,10 +101,10 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-source
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Brokers"
password: "The Password"
topic: "The Topic Names"
- username: "The Username"
+ user: "The Username"
sink:
ref:
kind: KafkaTopic
@@ -131,7 +131,7 @@ The procedure described above can be simplified into a single execution of the `
[source,shell]
----
-kamel bind kafka-source -p "source.brokers=The Brokers" -p "source.password=The Password" -p "source.topic=The Topic Names" -p "source.username=The Username" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
+kamel bind kafka-source -p "source.bootstrapServers=The Brokers" -p "source.password=The Password" -p "source.topic=The Topic Names" -p "source.user=The Username" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
----
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.
[camel-kamelets] 01/03: Kafka Source/Sink Kamelets: Changing the
parameters name for bootstrap server and user
Posted by ac...@apache.org.
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
commit 2b3354b26ba930b79c2a5f1b2bdf0c78de19a012
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jul 19 08:04:07 2021 +0200
Kafka Source/Sink Kamelets: Changing the parameters name for bootstrap server and user
---
kafka-sink.kamelet.yaml | 12 ++++++------
kafka-source.kamelet.yaml | 12 ++++++------
2 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/kafka-sink.kamelet.yaml b/kafka-sink.kamelet.yaml
index 11a706d..9be0fda 100644
--- a/kafka-sink.kamelet.yaml
+++ b/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/kafka-source.kamelet.yaml b/kafka-source.kamelet.yaml
index af65df6..b219149 100644
--- a/kafka-source.kamelet.yaml
+++ b/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}}"
[camel-kamelets] 02/03: Kafka Source/Sink Kamelets: Changing the
parameters name for bootstrap server and user
Posted by ac...@apache.org.
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
commit 151ad207394f3b7121221d68e7890e4e8d00499d
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}}"