[camel-kamelets] 01/03: Added Azure Eventhubs Sink Kamelet

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch azure-eventhubs-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 354f8876517400a0a58c6bb01daef02daae24d98
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 16 14:33:43 2021 +0200

    Added Azure Eventhubs Sink Kamelet
---
 azure-eventhubs-sink.kamelet.yaml | 71 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 71 insertions(+)

diff --git a/azure-eventhubs-sink.kamelet.yaml b/azure-eventhubs-sink.kamelet.yaml
new file mode 100644
index 0000000..9208f06
--- /dev/null
+++ b/azure-eventhubs-sink.kamelet.yaml
@@ -0,0 +1,71 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+  name: azure-eventhubs-sink
+  annotations:
+    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyBoZWlnaHQ9IjI1MDAiIHZpZXdCb3g9Ii0uMDc1IC0uMTc0IDE1OC40IDE2My4xMDEiIHdpZHRoPSIyNDM5IiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciPjxnIGZpbGw9IiMwMDZmZDQiPjxwYXRoIGQ9Im02LjIyNS4wMjZoMTQ2LjZjMS4zIDAgMy0uMiA0LjEuNS45LjYuOCAxLjUuOCAyLjR2MzEuOGMwIC45LS4xIDEuOC0uOCAyLjQtLjguOC0xLjcuOC0yLjguOGgtMTQuMWMtMS4yIDAtMi40LS4xLTMuMi0xLS43LS44LS43LTEuOS0uNy0yLjl2LTEyLjVoLTExNHYxMi44YzAgMS0uMSAyLS44IDIuOC0uOC44LTEuOC44LTIuOC44aC0xNC44Yy [...]
+    camel.apache.org/provider: "Apache Software Foundation"
+  labels:
+    camel.apache.org/kamelet.type: "sink"
+spec:
+  definition:
+    title: "Azure Eventhubs Sink"
+    description: |-
+      Send Events to Azure Eventhubs.
+
+      The Kamelet is able to understand the following headers to be set:
+
+      - `partition` / `ce-partition`: as the time to live of the message in the queue.
+
+      If the header won't be set then the partition will be assigned by Eventhubs
+    required:
+      - namespaceName
+      - eventhubName
+      - sharedAccessName
+      - sharedAccessKey
+    properties:
+      namespaceName:
+        title: Eventhubs Namespace
+        description: The eventhubs namespace
+        type: string
+      eventhubName:
+        title: Eventhubs name
+        description: The eventhub name
+        type: boolean
+        type: string
+      sharedAccessName:
+        title: Share access name
+        description: EventHubs SAS key name
+        type: string
+      sharedAccessKey:
+        title: Share access key
+        description: The key for EventHubs SAS key name
+        type: string
+        x-descriptors:
+        - urn:alm:descriptor:com.tectonic.ui:password
+  dependencies:
+  - "mvn:com.fasterxml.jackson.core:jackson-core:2.11.3"
+  - "mvn:com.fasterxml.jackson.core:jackson-annotations:2.11.3"
+  - "mvn:com.fasterxml.jackson.core:jackson-databind:2.11.3"
+  - "mvn:com.fasterxml.jackson.dataformat:jackson-dataformat-xml:2.11.3"
+  flow:
+    from:
+      uri: "kamelet:source"
+      steps:
+      - choice:
+          when:
+          - simple: "${header[partition]}"
+            steps:
+            - set-header:
+                name: CamelAzureEventHubsPartitionId
+                simple: "${header[partition]}"
+          - simple: "${header[ce-partition]}"
+            steps:
+            - set-header:
+                name: CamelAzureEventHubsPartitionId
+                simple: "${header[ce-partition]}"
+      - to:
+          uri: "azure-eventhubs://{{namespaceName}}/{{eventhubName}}"
+          parameters:
+            sharedAccessName: "{{sharedAccessName}}"
+            sharedAccessKey: "{{sharedAccessKey}}"