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/05/04 12:24:08 UTC
[camel-kamelets] branch main updated (b9bc1f9 -> 692aa5c)
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 b9bc1f9 Jenkinsfile deploy: No need for skipping archetypes in this repo
new a8ea59d Added Kafka Not Secured sink Kamelet
new 2aab890 Added Kafka Not Secured sink Kamelet
new 10ea579 Added Kafka Not Secured sink Kamelet
new 692aa5c Added Kafka Not Secured sink Kamelet
The 4 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:
...kafka-source.svg => kafka-not-secured-sink.svg} | 0
docs/modules/ROOT/nav.adoc | 1 +
...red-source.adoc => kafka-not-secured-sink.adoc} | 42 +++++++++++--------
...let.yaml => kafka-not-secured-sink.kamelet.yaml | 49 ++++++++++++++++++----
...et.yaml => kafka-not-secured-sink.kamelet.yaml} | 49 ++++++++++++++++++----
5 files changed, 108 insertions(+), 33 deletions(-)
copy docs/modules/ROOT/assets/images/kamelets/{kafka-source.svg => kafka-not-secured-sink.svg} (100%)
copy docs/modules/ROOT/pages/{kafka-not-secured-source.adoc => kafka-not-secured-sink.adoc} (56%)
copy library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml => kafka-not-secured-sink.kamelet.yaml (70%)
copy library/camel-kamelets-catalog/src/main/resources/kamelets/{kafka-not-secured-source.kamelet.yaml => kafka-not-secured-sink.kamelet.yaml} (70%)
[camel-kamelets] 03/04: Added Kafka Not Secured sink Kamelet
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 10ea579b6a967f53b2977f6b7d17925901b0f70a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 4 13:17:21 2021 +0200
Added Kafka Not Secured sink Kamelet
---
.../images/kamelets/kafka-not-secured-sink.svg | 19 ++++++
.../modules/ROOT/pages/kafka-not-secured-sink.adoc | 70 ++++++++++++++++++++++
2 files changed, 89 insertions(+)
diff --git a/docs/modules/ROOT/assets/images/kamelets/kafka-not-secured-sink.svg b/docs/modules/ROOT/assets/images/kamelets/kafka-not-secured-sink.svg
new file mode 100644
index 0000000..9d0e127
--- /dev/null
+++ b/docs/modules/ROOT/assets/images/kamelets/kafka-not-secured-sink.svg
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="utf-8"?>
+<!-- Generator: Adobe Illustrator 19.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) -->
+<svg version="1.1" id="Layer_1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" x="0px" y="0px"
+ viewBox="0 0 500 500" style="enable-background:new 0 0 500 500;" xml:space="preserve">
+<g id="XMLID_1_">
+ <path id="XMLID_9_" d="M314.8,269.7c-14.2,0-27,6.3-35.7,16.2L256.8,270c2.4-6.5,3.7-13.6,3.7-20.9c0-7.2-1.3-14.1-3.6-20.6
+ l22.3-15.7c8.7,9.9,21.4,16.1,35.6,16.1c26.2,0,47.6-21.3,47.6-47.6s-21.3-47.6-47.6-47.6s-47.6,21.3-47.6,47.6
+ c0,4.7,0.7,9.2,2,13.5l-22.3,15.7c-9.3-11.6-22.8-19.6-38.1-22.1v-26.9c21.6-4.5,37.8-23.7,37.8-46.6c0-26.2-21.3-47.6-47.6-47.6
+ c-26.2,0-47.6,21.3-47.6,47.6c0,22.6,15.8,41.5,36.9,46.3v27.3c-28.8,5.1-50.8,30.2-50.8,60.5c0,30.4,22.2,55.7,51.2,60.5v28.8
+ c-21.3,4.7-37.4,23.7-37.4,46.4c0,26.2,21.3,47.6,47.6,47.6c26.2,0,47.6-21.3,47.6-47.6c0-22.7-16-41.8-37.4-46.4v-28.8
+ c15-2.5,28.2-10.4,37.4-21.8l22.5,15.9c-1.2,4.3-1.9,8.7-1.9,13.4c0,26.2,21.3,47.6,47.6,47.6s47.6-21.3,47.6-47.6
+ C362.4,291,341.1,269.7,314.8,269.7z M314.8,158.4c12.7,0,23.1,10.4,23.1,23.1c0,12.7-10.3,23.1-23.1,23.1s-23.1-10.4-23.1-23.1
+ C291.8,168.8,302.1,158.4,314.8,158.4z M176,115.1c0-12.7,10.3-23.1,23.1-23.1c12.7,0,23.1,10.4,23.1,23.1
+ c0,12.7-10.3,23.1-23.1,23.1C186.3,138.2,176,127.8,176,115.1z M222.1,384.9c0,12.7-10.3,23.1-23.1,23.1
+ c-12.7,0-23.1-10.4-23.1-23.1c0-12.7,10.3-23.1,23.1-23.1C211.8,361.8,222.1,372.2,222.1,384.9z M199.1,281.3
+ c-17.7,0-32.2-14.4-32.2-32.2c0-17.7,14.4-32.2,32.2-32.2c17.7,0,32.2,14.4,32.2,32.2C231.2,266.9,216.8,281.3,199.1,281.3z
+ M314.8,340.3c-12.7,0-23.1-10.4-23.1-23.1c0-12.7,10.3-23.1,23.1-23.1s23.1,10.4,23.1,23.1C337.9,330,327.5,340.3,314.8,340.3z"/>
+</g>
+</svg>
diff --git a/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc b/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
new file mode 100644
index 0000000..124d2cf
--- /dev/null
+++ b/docs/modules/ROOT/pages/kafka-not-secured-sink.adoc
@@ -0,0 +1,70 @@
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT
+= image:kamelets/kafka-not-secured-sink.svg[] Kafka Not Secured Sink
+
+*Provided by: "Apache Software Foundation"*
+
+Send data to Kafka topics.
+
+The Kamelet is able to understand the following headers to be set:
+
+- `key` / `ce-key`: as message key
+
+- `partition-key` / `paritition-key`: as message partition key
+
+Both the headers are optional.
+
+== Configuration Options
+
+The following table summarizes the configuration options available for the `kafka-not-secured-sink` Kamelet:
+[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| |
+| *topic {empty}* *| Topic Names| Comma separated list of Kafka topic names| string| |
+|===
+
+NOTE: Fields marked with ({empty}*) are mandatory.
+
+== Usage
+
+This section summarizes how the `kafka-not-secured-sink` can be used in various contexts.
+
+=== Knative Sink
+
+The `kafka-not-secured-sink` Kamelet can be used as Knative sink by binding it to a Knative object.
+
+.kafka-not-secured-sink-binding.yaml
+[source,yaml]
+----
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+ name: kafka-not-secured-sink-binding
+spec:
+ source:
+ ref:
+ kind: InMemoryChannel
+ apiVersion: messaging.knative.dev/v1
+ name: mychannel
+ sink:
+ ref:
+ kind: Kamelet
+ apiVersion: camel.apache.org/v1alpha1
+ name: kafka-not-secured-sink
+ properties:
+ brokers: "The Brokers"
+ topic: "The Topic Names"
+
+----
+
+Make sure you have xref:latest@camel-k::installation/installation.adoc[Camel K installed] into the Kubernetes cluster you're connected to.
+
+Save the `kafka-not-secured-sink-binding.yaml` file into your hard drive, then configure it according to your needs.
+
+You can run the sink using the following command:
+
+[source,shell]
+----
+kubectl apply -f kafka-not-secured-sink-binding.yaml
+----
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT
[camel-kamelets] 01/04: Added Kafka Not Secured sink Kamelet
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 a8ea59da7b9cddf217112cd2333150fdc57e136b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 4 13:15:35 2021 +0200
Added Kafka Not Secured sink Kamelet
---
kafka-not-secured-sink.kamelet.yaml | 67 +++++++++++++++++++++++++++++++++++++
1 file changed, 67 insertions(+)
diff --git a/kafka-not-secured-sink.kamelet.yaml b/kafka-not-secured-sink.kamelet.yaml
new file mode 100644
index 0000000..a0872ee
--- /dev/null
+++ b/kafka-not-secured-sink.kamelet.yaml
@@ -0,0 +1,67 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: kafka-not-secured-sink
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0idXRmLTgiPz4NCjwhLS0gR2VuZXJhdG9yOiBBZG9iZSBJbGx1c3RyYXRvciAxOS4wLjAsIFNWRyBFeHBvcnQgUGx1Zy1JbiAuIFNWRyBWZXJzaW9uOiA2LjAwIEJ1aWxkIDApICAtLT4NCjxzdmcgdmVyc2lvbj0iMS4xIiBpZD0iTGF5ZXJfMSIgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiB4bWxuczp4bGluaz0iaHR0cDovL3d3dy53My5vcmcvMTk5OS94bGluayIgeD0iMHB4IiB5PSIwcHgiDQoJIHZpZXdCb3g9IjAgMCA1MDAgNTAwIiBzdHlsZT0iZW5hYmxlLWJhY2tncm91bmQ6bmV3IDAgMCA1MD [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+spec:
+ definition:
+ title: "Kafka Not Secured Sink"
+ description: |-
+ Send data to Kafka topics.
+
+ The Kamelet is able to understand the following headers to be set:
+
+ - `key` / `ce-key`: as message key
+
+ - `partition-key` / `paritition-key`: as message partition key
+
+ Both the headers are optional.
+ required:
+ - topic
+ - brokers
+ type: object
+ properties:
+ topic:
+ title: Topic Names
+ description: Comma separated list of Kafka topic names
+ type: string
+ brokers:
+ title: Brokers
+ description: Comma separated list of Kafka Broker URLs
+ type: string
+ flow:
+ from:
+ uri: "kamelet:source"
+ steps:
+ - choice:
+ when:
+ - simple: "${header[key]}"
+ steps:
+ - set-header:
+ name: kafka.KEY
+ simple: "${header[key]}"
+ - simple: "${header[ce-key]}"
+ steps:
+ - set-header:
+ name: kafka.KEY
+ simple: "${header[ce-key]}"
+ - choice:
+ when:
+ - simple: "${header[partition-key]}"
+ steps:
+ - set-header:
+ name: kafka.PARTITION_KEY
+ simple: "${header[partition-key]}"
+ - simple: "${header[ce-partition-key]}"
+ steps:
+ - set-header:
+ name: kafka.PARTITION_KEY
+ simple: "${header[ce-partition-key]}"
+ - to:
+ uri: "kafka:{{topic}}"
+ parameters:
+ brokers: "{{brokers}}"
[camel-kamelets] 02/04: Added Kafka Not Secured sink Kamelet
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 2aab8908e83b4e892588e08ead12bc925d705edf
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 4 13:17:06 2021 +0200
Added Kafka Not Secured sink Kamelet
---
docs/modules/ROOT/nav.adoc | 1 +
1 file changed, 1 insertion(+)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index edcdf34..d42452f 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -45,6 +45,7 @@
* xref:ROOT:insert-field-action.adoc[image:kamelets/insert-field-action.svg[] Insert Field]
* xref:ROOT:insert-header-action.adoc[image:kamelets/insert-header-action.svg[] Insert Header]
* xref:ROOT:jira-source.adoc[image:kamelets/jira-source.svg[] Jira Source]
+* xref:ROOT:kafka-not-secured-sink.adoc[image:kamelets/kafka-not-secured-sink.svg[] Kafka Not Secured Sink]
* xref:ROOT:kafka-not-secured-source.adoc[image:kamelets/kafka-not-secured-source.svg[] Kafka Not Secured Source]
* xref:ROOT:kafka-source.adoc[image:kamelets/kafka-source.svg[] Kafka Source]
* xref:ROOT:mail-imap-source.adoc[image:kamelets/mail-imap-source.svg[] Mail IMAP Source]
[camel-kamelets] 04/04: Added Kafka Not Secured sink Kamelet
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 692aa5c1f74036408ad5657392aece0f87470896
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue May 4 13:18:09 2021 +0200
Added Kafka Not Secured sink Kamelet
---
.../kamelets/kafka-not-secured-sink.kamelet.yaml | 67 ++++++++++++++++++++++
1 file changed, 67 insertions(+)
diff --git a/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml
new file mode 100644
index 0000000..a0872ee
--- /dev/null
+++ b/library/camel-kamelets-catalog/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml
@@ -0,0 +1,67 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: kafka-not-secured-sink
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0idXRmLTgiPz4NCjwhLS0gR2VuZXJhdG9yOiBBZG9iZSBJbGx1c3RyYXRvciAxOS4wLjAsIFNWRyBFeHBvcnQgUGx1Zy1JbiAuIFNWRyBWZXJzaW9uOiA2LjAwIEJ1aWxkIDApICAtLT4NCjxzdmcgdmVyc2lvbj0iMS4xIiBpZD0iTGF5ZXJfMSIgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiB4bWxuczp4bGluaz0iaHR0cDovL3d3dy53My5vcmcvMTk5OS94bGluayIgeD0iMHB4IiB5PSIwcHgiDQoJIHZpZXdCb3g9IjAgMCA1MDAgNTAwIiBzdHlsZT0iZW5hYmxlLWJhY2tncm91bmQ6bmV3IDAgMCA1MD [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+spec:
+ definition:
+ title: "Kafka Not Secured Sink"
+ description: |-
+ Send data to Kafka topics.
+
+ The Kamelet is able to understand the following headers to be set:
+
+ - `key` / `ce-key`: as message key
+
+ - `partition-key` / `paritition-key`: as message partition key
+
+ Both the headers are optional.
+ required:
+ - topic
+ - brokers
+ type: object
+ properties:
+ topic:
+ title: Topic Names
+ description: Comma separated list of Kafka topic names
+ type: string
+ brokers:
+ title: Brokers
+ description: Comma separated list of Kafka Broker URLs
+ type: string
+ flow:
+ from:
+ uri: "kamelet:source"
+ steps:
+ - choice:
+ when:
+ - simple: "${header[key]}"
+ steps:
+ - set-header:
+ name: kafka.KEY
+ simple: "${header[key]}"
+ - simple: "${header[ce-key]}"
+ steps:
+ - set-header:
+ name: kafka.KEY
+ simple: "${header[ce-key]}"
+ - choice:
+ when:
+ - simple: "${header[partition-key]}"
+ steps:
+ - set-header:
+ name: kafka.PARTITION_KEY
+ simple: "${header[partition-key]}"
+ - simple: "${header[ce-partition-key]}"
+ steps:
+ - set-header:
+ name: kafka.PARTITION_KEY
+ simple: "${header[ce-partition-key]}"
+ - to:
+ uri: "kafka:{{topic}}"
+ parameters:
+ brokers: "{{brokers}}"