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/12/09 17:39:54 UTC
[camel-kamelets] branch main updated (912d59f -> e8d8bfe)
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 912d59f #76: Add Pulsar source Kamelet
new e6d903e Rename brokers into bootstrapServers
new e8d8bfe Update doc and regen
The 2 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-not-secured-sink.adoc | 10 +++++-----
docs/modules/ROOT/pages/kafka-not-secured-source.adoc | 10 +++++-----
docs/modules/ROOT/pages/kafka-sink.adoc | 10 +++++-----
docs/modules/ROOT/pages/kafka-source.adoc | 10 +++++-----
kamelets/kafka-not-secured-sink.kamelet.yaml | 8 ++++----
kamelets/kafka-not-secured-source.kamelet.yaml | 8 ++++----
kamelets/kafka-sink.kamelet.yaml | 2 +-
kamelets/kafka-source.kamelet.yaml | 2 +-
.../resources/kamelets/kafka-not-secured-sink.kamelet.yaml | 8 ++++----
.../resources/kamelets/kafka-not-secured-source.kamelet.yaml | 8 ++++----
.../src/main/resources/kamelets/kafka-sink.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-source.kamelet.yaml | 2 +-
templates/bindings/camel-k/kafka-not-secured-sink-binding.yaml | 2 +-
.../bindings/camel-k/kafka-not-secured-source-binding.yaml | 2 +-
templates/bindings/camel-k/kafka-sink-binding.yaml | 2 +-
templates/bindings/camel-k/kafka-source-binding.yaml | 2 +-
templates/bindings/core/kafka-not-secured-sink-binding.yaml | 2 +-
templates/bindings/core/kafka-not-secured-source-binding.yaml | 2 +-
templates/bindings/core/kafka-sink-binding.yaml | 2 +-
templates/bindings/core/kafka-source-binding.yaml | 2 +-
20 files changed, 48 insertions(+), 48 deletions(-)
[camel-kamelets] 02/02: Update doc and regen
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 e8d8bfef08dc5936aff8e526bc8c5262cee63250
Author: nicolaferraro <ni...@gmail.com>
AuthorDate: Thu Dec 9 16:40:52 2021 +0100
Update doc and regen
---
docs/modules/ROOT/pages/kafka-not-secured-sink.adoc | 10 +++++-----
docs/modules/ROOT/pages/kafka-not-secured-source.adoc | 10 +++++-----
docs/modules/ROOT/pages/kafka-sink.adoc | 10 +++++-----
docs/modules/ROOT/pages/kafka-source.adoc | 10 +++++-----
.../resources/kamelets/kafka-not-secured-sink.kamelet.yaml | 8 ++++----
.../resources/kamelets/kafka-not-secured-source.kamelet.yaml | 8 ++++----
.../src/main/resources/kamelets/kafka-sink.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/kafka-source.kamelet.yaml | 2 +-
templates/bindings/camel-k/kafka-not-secured-sink-binding.yaml | 2 +-
.../bindings/camel-k/kafka-not-secured-source-binding.yaml | 2 +-
templates/bindings/camel-k/kafka-sink-binding.yaml | 2 +-
templates/bindings/camel-k/kafka-source-binding.yaml | 2 +-
templates/bindings/core/kafka-not-secured-sink-binding.yaml | 2 +-
templates/bindings/core/kafka-not-secured-source-binding.yaml | 2 +-
templates/bindings/core/kafka-sink-binding.yaml | 2 +-
templates/bindings/core/kafka-source-binding.yaml | 2 +-
16 files changed, 38 insertions(+), 38 deletions(-)
diff --git a/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc b/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
index ebfc9e3..62efcb6 100644
--- a/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
+++ b/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
@@ -22,7 +22,7 @@ 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}* *| Bootstrap Servers| Comma separated list of Kafka Broker URLs| string| |
| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| |
|===
@@ -63,7 +63,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-not-secured-sink
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
----
@@ -89,7 +89,7 @@ Configure and run the sink by using the following command:
[source,shell]
----
-kamel bind channel:mychannel kafka-not-secured-sink -p "sink.brokers=The Brokers" -p "sink.topic=The Topic Names"
+kamel bind channel:mychannel kafka-not-secured-sink -p "sink.bootstrapServers=The Bootstrap Servers" -p "sink.topic=The Topic Names"
----
This command creates the KameletBinding in the current namespace on the cluster.
@@ -117,7 +117,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-not-secured-sink
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
----
@@ -145,7 +145,7 @@ Configure and run the sink by using the following command:
[source,shell]
----
-kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic kafka-not-secured-sink -p "sink.brokers=The Brokers" -p "sink.topic=The Topic Names"
+kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic kafka-not-secured-sink -p "sink.bootstrapServers=The Bootstrap Servers" -p "sink.topic=The Topic Names"
----
This command creates the KameletBinding in the current namespace on the cluster.
diff --git a/docs/modules/ROOT/pages/kafka-not-secured-source.adoc b/docs/modules/ROOT/pages/kafka-not-secured-source.adoc
index db10ae1..77478ec 100644
--- a/docs/modules/ROOT/pages/kafka-not-secured-source.adoc
+++ b/docs/modules/ROOT/pages/kafka-not-secured-source.adoc
@@ -14,7 +14,7 @@ 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}* *| Bootstrap Servers| Comma separated list of Kafka Broker URLs| string| |
| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| 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`|
@@ -55,7 +55,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-not-secured-source
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
sink:
ref:
@@ -86,7 +86,7 @@ Configure and run the source by using the following command:
[source,shell]
----
-kamel bind kafka-not-secured-source -p "source.brokers=The Brokers" -p "source.topic=The Topic Names" channel:mychannel
+kamel bind kafka-not-secured-source -p "source.bootstrapServers=The Bootstrap Servers" -p "source.topic=The Topic Names" channel:mychannel
----
This command creates the KameletBinding in the current namespace on the cluster.
@@ -109,7 +109,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-not-secured-source
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
sink:
ref:
@@ -142,7 +142,7 @@ Configure and run the source by using the following command:
[source,shell]
----
-kamel bind kafka-not-secured-source -p "source.brokers=The Brokers" -p "source.topic=The Topic Names" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
+kamel bind kafka-not-secured-source -p "source.bootstrapServers=The Bootstrap Servers" -p "source.topic=The Topic Names" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
----
This command creates the KameletBinding in the current namespace on the cluster.
diff --git a/docs/modules/ROOT/pages/kafka-sink.adoc b/docs/modules/ROOT/pages/kafka-sink.adoc
index dbd0aab..737d279 100644
--- a/docs/modules/ROOT/pages/kafka-sink.adoc
+++ b/docs/modules/ROOT/pages/kafka-sink.adoc
@@ -22,7 +22,7 @@ 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
-| *bootstrapServers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
+| *bootstrapServers {empty}* *| Bootstrap Servers| 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| |
| *user {empty}* *| Username| Username to authenticate to Kafka| string| |
@@ -67,7 +67,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-sink
properties:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
@@ -95,7 +95,7 @@ Configure and run the sink by using the following command:
[source,shell]
----
-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"
+kamel bind channel:mychannel kafka-sink -p "sink.bootstrapServers=The Bootstrap Servers" -p "sink.password=The Password" -p "sink.topic=The Topic Names" -p "sink.user=The Username"
----
This command creates the KameletBinding in the current namespace on the cluster.
@@ -123,7 +123,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-sink
properties:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
@@ -153,7 +153,7 @@ Configure and run the sink by using the following command:
[source,shell]
----
-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"
+kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic kafka-sink -p "sink.bootstrapServers=The Bootstrap Servers" -p "sink.password=The Password" -p "sink.topic=The Topic Names" -p "sink.user=The Username"
----
This command creates the KameletBinding in the current namespace on the cluster.
diff --git a/docs/modules/ROOT/pages/kafka-source.adoc b/docs/modules/ROOT/pages/kafka-source.adoc
index eddfa26..f360fd1 100644
--- a/docs/modules/ROOT/pages/kafka-source.adoc
+++ b/docs/modules/ROOT/pages/kafka-source.adoc
@@ -14,7 +14,7 @@ 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
-| *bootstrapServers {empty}* *| Brokers| Comma separated list of Kafka Broker URLs| string| |
+| *bootstrapServers {empty}* *| Bootstrap Servers| 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| |
| *user {empty}* *| Username| Username to authenticate to Kafka| string| |
@@ -59,7 +59,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-source
properties:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
@@ -92,7 +92,7 @@ Configure and run the source by using the following command:
[source,shell]
----
-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
+kamel bind kafka-source -p "source.bootstrapServers=The Bootstrap Servers" -p "source.password=The Password" -p "source.topic=The Topic Names" -p "source.user=The Username" channel:mychannel
----
This command creates the KameletBinding in the current namespace on the cluster.
@@ -115,7 +115,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-source
properties:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
@@ -150,7 +150,7 @@ Configure and run the source by using the following command:
[source,shell]
----
-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
+kamel bind kafka-source -p "source.bootstrapServers=The Bootstrap Servers" -p "source.password=The Password" -p "source.topic=The Topic Names" -p "source.user=The Username" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
----
This command creates the KameletBinding in the current namespace on the cluster.
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml
index 9a960e3..6858cec 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml
@@ -41,15 +41,15 @@ spec:
Both the headers are optional.
required:
- topic
- - brokers
+ - bootstrapServers
type: object
properties:
topic:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- brokers:
- title: Brokers
+ bootstrapServers:
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
dependencies:
@@ -86,4 +86,4 @@ spec:
- to:
uri: "kafka:{{topic}}"
parameters:
- brokers: "{{brokers}}"
+ brokers: "{{bootstrapServers}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
index 3e6232a..adc52f8 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -33,15 +33,15 @@ spec:
Receive data from Kafka topics on an insecure broker.
required:
- topic
- - brokers
+ - bootstrapServers
type: object
properties:
topic:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- brokers:
- title: Brokers
+ bootstrapServers:
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
autoCommitEnable:
@@ -80,7 +80,7 @@ spec:
from:
uri: "kafka:{{topic}}"
parameters:
- brokers: "{{brokers}}"
+ brokers: "{{bootstrapServers}}"
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"
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 d50644d..7523901 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
@@ -51,7 +51,7 @@ spec:
description: Comma separated list of Kafka topic names
type: string
bootstrapServers:
- title: Brokers
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
securityProtocol:
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 102a0f5..8167e8a 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
@@ -43,7 +43,7 @@ spec:
description: Comma separated list of Kafka topic names
type: string
bootstrapServers:
- title: Brokers
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
securityProtocol:
diff --git a/templates/bindings/camel-k/kafka-not-secured-sink-binding.yaml b/templates/bindings/camel-k/kafka-not-secured-sink-binding.yaml
index cbfbe31..13165e7 100644
--- a/templates/bindings/camel-k/kafka-not-secured-sink-binding.yaml
+++ b/templates/bindings/camel-k/kafka-not-secured-sink-binding.yaml
@@ -14,6 +14,6 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-not-secured-sink
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
\ No newline at end of file
diff --git a/templates/bindings/camel-k/kafka-not-secured-source-binding.yaml b/templates/bindings/camel-k/kafka-not-secured-source-binding.yaml
index bbc4bfe..d004de8 100644
--- a/templates/bindings/camel-k/kafka-not-secured-source-binding.yaml
+++ b/templates/bindings/camel-k/kafka-not-secured-source-binding.yaml
@@ -9,7 +9,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-not-secured-source
properties:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
sink:
ref:
diff --git a/templates/bindings/camel-k/kafka-sink-binding.yaml b/templates/bindings/camel-k/kafka-sink-binding.yaml
index acb775d..9e66640 100644
--- a/templates/bindings/camel-k/kafka-sink-binding.yaml
+++ b/templates/bindings/camel-k/kafka-sink-binding.yaml
@@ -14,7 +14,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-sink
properties:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
diff --git a/templates/bindings/camel-k/kafka-source-binding.yaml b/templates/bindings/camel-k/kafka-source-binding.yaml
index ef5359c..6a8882c 100644
--- a/templates/bindings/camel-k/kafka-source-binding.yaml
+++ b/templates/bindings/camel-k/kafka-source-binding.yaml
@@ -9,7 +9,7 @@ spec:
apiVersion: camel.apache.org/v1alpha1
name: kafka-source
properties:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
diff --git a/templates/bindings/core/kafka-not-secured-sink-binding.yaml b/templates/bindings/core/kafka-not-secured-sink-binding.yaml
index d6136f9..7b4e900 100644
--- a/templates/bindings/core/kafka-not-secured-sink-binding.yaml
+++ b/templates/bindings/core/kafka-not-secured-sink-binding.yaml
@@ -8,6 +8,6 @@
- to:
uri: "kamelet:kafka-not-secured-sink"
parameters:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
\ No newline at end of file
diff --git a/templates/bindings/core/kafka-not-secured-source-binding.yaml b/templates/bindings/core/kafka-not-secured-source-binding.yaml
index 85315ad..c03aa36 100644
--- a/templates/bindings/core/kafka-not-secured-source-binding.yaml
+++ b/templates/bindings/core/kafka-not-secured-source-binding.yaml
@@ -2,7 +2,7 @@
from:
uri: "kamelet:kafka-not-secured-source"
parameters:
- brokers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
topic: "The Topic Names"
steps:
- to:
diff --git a/templates/bindings/core/kafka-sink-binding.yaml b/templates/bindings/core/kafka-sink-binding.yaml
index e50a882..c2cc736 100644
--- a/templates/bindings/core/kafka-sink-binding.yaml
+++ b/templates/bindings/core/kafka-sink-binding.yaml
@@ -8,7 +8,7 @@
- to:
uri: "kamelet:kafka-sink"
parameters:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
diff --git a/templates/bindings/core/kafka-source-binding.yaml b/templates/bindings/core/kafka-source-binding.yaml
index 2b00814..d0c8f7d 100644
--- a/templates/bindings/core/kafka-source-binding.yaml
+++ b/templates/bindings/core/kafka-source-binding.yaml
@@ -2,7 +2,7 @@
from:
uri: "kamelet:kafka-source"
parameters:
- bootstrapServers: "The Brokers"
+ bootstrapServers: "The Bootstrap Servers"
password: "The Password"
topic: "The Topic Names"
user: "The Username"
[camel-kamelets] 01/02: Rename brokers into bootstrapServers
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 e6d903ed1df57f3c987129ce1c7be32345ef0ffc
Author: nicolaferraro <ni...@gmail.com>
AuthorDate: Thu Dec 9 16:38:25 2021 +0100
Rename brokers into bootstrapServers
---
kamelets/kafka-not-secured-sink.kamelet.yaml | 8 ++++----
kamelets/kafka-not-secured-source.kamelet.yaml | 8 ++++----
kamelets/kafka-sink.kamelet.yaml | 2 +-
kamelets/kafka-source.kamelet.yaml | 2 +-
4 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/kamelets/kafka-not-secured-sink.kamelet.yaml b/kamelets/kafka-not-secured-sink.kamelet.yaml
index 9a960e3..6858cec 100644
--- a/kamelets/kafka-not-secured-sink.kamelet.yaml
+++ b/kamelets/kafka-not-secured-sink.kamelet.yaml
@@ -41,15 +41,15 @@ spec:
Both the headers are optional.
required:
- topic
- - brokers
+ - bootstrapServers
type: object
properties:
topic:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- brokers:
- title: Brokers
+ bootstrapServers:
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
dependencies:
@@ -86,4 +86,4 @@ spec:
- to:
uri: "kafka:{{topic}}"
parameters:
- brokers: "{{brokers}}"
+ brokers: "{{bootstrapServers}}"
diff --git a/kamelets/kafka-not-secured-source.kamelet.yaml b/kamelets/kafka-not-secured-source.kamelet.yaml
index 3e6232a..adc52f8 100644
--- a/kamelets/kafka-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-not-secured-source.kamelet.yaml
@@ -33,15 +33,15 @@ spec:
Receive data from Kafka topics on an insecure broker.
required:
- topic
- - brokers
+ - bootstrapServers
type: object
properties:
topic:
title: Topic Names
description: Comma separated list of Kafka topic names
type: string
- brokers:
- title: Brokers
+ bootstrapServers:
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
autoCommitEnable:
@@ -80,7 +80,7 @@ spec:
from:
uri: "kafka:{{topic}}"
parameters:
- brokers: "{{brokers}}"
+ brokers: "{{bootstrapServers}}"
autoCommitEnable: "{{autoCommitEnable}}"
allowManualCommit: "{{allowManualCommit}}"
pollOnError: "{{pollOnError}}"
diff --git a/kamelets/kafka-sink.kamelet.yaml b/kamelets/kafka-sink.kamelet.yaml
index d50644d..7523901 100644
--- a/kamelets/kafka-sink.kamelet.yaml
+++ b/kamelets/kafka-sink.kamelet.yaml
@@ -51,7 +51,7 @@ spec:
description: Comma separated list of Kafka topic names
type: string
bootstrapServers:
- title: Brokers
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
securityProtocol:
diff --git a/kamelets/kafka-source.kamelet.yaml b/kamelets/kafka-source.kamelet.yaml
index 102a0f5..8167e8a 100644
--- a/kamelets/kafka-source.kamelet.yaml
+++ b/kamelets/kafka-source.kamelet.yaml
@@ -43,7 +43,7 @@ spec:
description: Comma separated list of Kafka topic names
type: string
bootstrapServers:
- title: Brokers
+ title: Bootstrap Servers
description: Comma separated list of Kafka Broker URLs
type: string
securityProtocol: