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/04/16 12:35:24 UTC

[camel-kamelets] branch azure-eventhubs-sink created (now 4eb8374)

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

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


      at 4eb8374  Added Azure Eventhubs Sink Kamelet

This branch includes the following new commits:

     new 354f887  Added Azure Eventhubs Sink Kamelet
     new b2e928b  Added Azure Eventhubs Sink Kamelet
     new 4eb8374  Added Azure Eventhubs Sink Kamelet

The 3 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.


[camel-kamelets] 03/03: Added Azure Eventhubs 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 azure-eventhubs-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 4eb8374c4d0cb4dce8552b7abda0cc5d2418f9b6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 16 14:34:58 2021 +0200

    Added Azure Eventhubs Sink Kamelet
---
 .../images/kamelets/azure-eventhubs-sink.svg       |  1 +
 docs/modules/ROOT/pages/azure-eventhubs-sink.adoc  | 72 ++++++++++++++++++++++
 2 files changed, 73 insertions(+)

diff --git a/docs/modules/ROOT/assets/images/kamelets/azure-eventhubs-sink.svg b/docs/modules/ROOT/assets/images/kamelets/azure-eventhubs-sink.svg
new file mode 100644
index 0000000..3d3037c
--- /dev/null
+++ b/docs/modules/ROOT/assets/images/kamelets/azure-eventhubs-sink.svg
@@ -0,0 +1 @@
+<svg height="2500" viewBox="-.075 -.174 158.4 163.101" width="2439" xmlns="http://www.w3.org/2000/svg"><g fill="#006fd4"><path d="m6.225.026h146.6c1.3 0 3-.2 4.1.5.9.6.8 1.5.8 2.4v31.8c0 .9-.1 1.8-.8 2.4-.8.8-1.7.8-2.8.8h-14.1c-1.2 0-2.4-.1-3.2-1-.7-.8-.7-1.9-.7-2.9v-12.5h-114v12.8c0 1-.1 2-.8 2.8-.8.8-1.8.8-2.8.8h-14.8c-1 0-2 0-2.8-.8-.8-.8-.8-1.7-.9-2.8v-28.8c0-1.1-.1-2.3.1-3.4.2-1 1.1-1.8 2.1-2 1.4-.2 2.7-.1 4-.1z"/><path d="m36.625 37.627h19.4c1.2 0 2.6.1 3.4 1.1.7.8.7 1.8.7 2.8v14.4 [...]
\ No newline at end of file
diff --git a/docs/modules/ROOT/pages/azure-eventhubs-sink.adoc b/docs/modules/ROOT/pages/azure-eventhubs-sink.adoc
new file mode 100644
index 0000000..78e47ff
--- /dev/null
+++ b/docs/modules/ROOT/pages/azure-eventhubs-sink.adoc
@@ -0,0 +1,72 @@
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT
+= image:kamelets/azure-eventhubs-sink.svg[] Azure Eventhubs Sink
+
+*Provided by: "Apache Software Foundation"*
+
+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
+
+== Configuration Options
+
+The following table summarizes the configuration options available for the `azure-eventhubs-sink` Kamelet:
+[width="100%",cols="2,^2,3,^2,^2,^3",options="header"]
+|===
+| Property| Name| Description| Type| Default| Example
+| *eventhubName {empty}* *| Eventhubs name| The eventhub name| string| | 
+| *namespaceName {empty}* *| Eventhubs Namespace| The eventhubs namespace| string| | 
+| *sharedAccessKey {empty}* *| Share access key| The key for EventHubs SAS key name| string| | 
+| *sharedAccessName {empty}* *| Share access name| EventHubs SAS key name| string| | 
+|===
+
+NOTE: Fields marked with ({empty}*) are mandatory.
+
+== Usage
+
+This section summarizes how the `azure-eventhubs-sink` can be used in various contexts.
+
+=== Knative Sink
+
+The `azure-eventhubs-sink` Kamelet can be used as Knative sink by binding it to a Knative object.
+
+.azure-eventhubs-sink-binding.yaml
+[source,yaml]
+----
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+  name: azure-eventhubs-sink-binding
+spec:
+  source:
+    ref:
+      kind: InMemoryChannel
+      apiVersion: messaging.knative.dev/v1
+      name: mychannel
+  sink:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: azure-eventhubs-sink
+    properties:
+      eventhubName: "The Eventhubs name"
+      namespaceName: "The Eventhubs Namespace"
+      sharedAccessKey: "The Share access key"
+      sharedAccessName: "The Share access name"
+
+----
+
+Make sure you have xref:latest@camel-k::installation/installation.adoc[Camel K installed] into the Kubernetes cluster you're connected to.
+
+Save the `azure-eventhubs-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 azure-eventhubs-sink-binding.yaml
+----
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT

[camel-kamelets] 01/03: Added Azure Eventhubs 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 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}}"

[camel-kamelets] 02/03: Added Azure Eventhubs 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 azure-eventhubs-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit b2e928b06d55924a511ebec40d3b59829bc7a24f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 16 14:34:47 2021 +0200

    Added Azure Eventhubs 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 8418d3b..8544f69 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -10,6 +10,7 @@
 * xref:ROOT:aws-sqs-fifo-sink.adoc[image:kamelets/aws-sqs-fifo-sink.svg[] AWS SQS FIFO Sink]
 * xref:ROOT:aws-sqs-sink.adoc[image:kamelets/aws-sqs-sink.svg[] AWS SQS Sink]
 * xref:ROOT:aws-sqs-source.adoc[image:kamelets/aws-sqs-source.svg[] AWS SQS Source]
+* xref:ROOT:azure-eventhubs-sink.adoc[image:kamelets/azure-eventhubs-sink.svg[] Azure Eventhubs Sink]
 * xref:ROOT:azure-eventhubs-source.adoc[image:kamelets/azure-eventhubs-source.svg[] Azure Eventhubs Source]
 * xref:ROOT:azure-storage-blob-sink.adoc[image:kamelets/azure-storage-blob-sink.svg[] Azure Storage Blob Sink]
 * xref:ROOT:azure-storage-blob-source.adoc[image:kamelets/azure-storage-blob-source.svg[] Azure Storage Blob Source]