This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch kafka-source in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit c05c9daacf89502f5ed8e4b31368073e19778ef6 Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Mar 1 15:16:57 2021 +0100 Added Kafka Source kamelet --- kafka-source.kamelet.yaml | 40 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 40 insertions(+) diff --git a/kafka-source.kamelet.yaml b/kafka-source.kamelet.yaml new file mode 100644 index 0000000..3baf168 --- /dev/null +++ b/kafka-source.kamelet.yaml @@ -0,0 +1,40 @@ +apiVersion: camel.apache.org/v1alpha1 +kind: Kamelet +metadata: + name: kafka-source + 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: "source" +spec: + definition: + title: "Kafka Source" + description: |- + Receive data from Kafka topics. + required: + - topic + - brokers + 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 + types: + out: + mediaType: application/json + dependencies: + - "camel:jackson" + flow: + from: + uri: "kafka:{{topic}}" + parameters: + brokers: "{{brokers}}" + steps: + - marshal: + json: {} + - to: "kamelet:sink"
