This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit fd3599cfc897c6d3f9bd72146b40b3db4cce56b8
Author: Andrea Cosentino <anco...@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}}"
