Azure Eventhubs Source
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Preview"
Receive events from Azure Eventhubs.
Configuration Options
The following table summarizes the configuration options available for the azure-eventhubs-source
Kamelet:
Property | Name | Description | Type | Default | Example |
---|---|---|---|---|---|
Azure Storage Blob Access Key |
Required The key for Azure Storage Blob service associated with the Blob account name. |
string |
|||
Azure Storage Blob Account Name |
Required The name of the storage blob account to be use. |
string |
|||
Azure Storage Blob Container Name |
Required The name of the storage blob container to be use. |
string |
|||
Eventhubs Name |
Required The eventhub name. |
string |
|||
Eventhubs Namespace |
Required The eventhubs namespace. |
string |
|||
Share Access Key |
Required The key for EventHubs SAS key name. |
string |
|||
Share Access Name |
Required EventHubs SAS key name. |
string |
Dependencies
At runtime, the azure-eventhubs-source
Kamelet relies upon the presence of the following 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
-
camel:azure-eventhubs
-
camel:kamelet
-
camel:jackson
Usage
This section describes how you can use the azure-eventhubs-source
.
Knative source
You can use the azure-eventhubs-source
Kamelet as a Knative source by binding it to a Knative object.
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: azure-eventhubs-source-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: azure-eventhubs-source
properties:
blobAccessKey: The Azure Storage Blob Access Key
blobAccountName: The Azure Storage Blob Account Name
blobContainerName: The Azure Storage Blob Container Name
eventhubName: The Eventhubs Name
namespaceName: The Eventhubs Namespace
sharedAccessKey: The Share Access Key
sharedAccessName: The Share Access Name
sink:
ref:
kind: Channel
apiVersion: messaging.knative.dev/v1
name: mychannel
Prerequisite
You have Camel K installed on the cluster.
Procedure for using the cluster CLI
-
Save the
azure-eventhubs-source-binding.yaml
file to your local drive, and then edit it as needed for your configuration. -
Run the source by using the following command:
kubectl apply -f azure-eventhubs-source-binding.yaml
Procedure for using the Kamel CLI
Configure and run the source by using the following command:
kamel bind azure-eventhubs-source -p "source.blobAccessKey=The Azure Storage Blob Access Key" -p "source.blobAccountName=The Azure Storage Blob Account Name" -p "source.blobContainerName=The Azure Storage Blob Container Name" -p "source.eventhubName=The Eventhubs Name" -p "source.namespaceName=The Eventhubs Namespace" -p "source.sharedAccessKey=The Share Access Key" -p "source.sharedAccessName=The Share Access Name" channel:mychannel
This command creates the KameletBinding in the current namespace on the cluster.
Kafka source
You can use the azure-eventhubs-source
Kamelet as a Kafka source by binding it to a Kafka topic.
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: azure-eventhubs-source-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: azure-eventhubs-source
properties:
blobAccessKey: The Azure Storage Blob Access Key
blobAccountName: The Azure Storage Blob Account Name
blobContainerName: The Azure Storage Blob Container Name
eventhubName: The Eventhubs Name
namespaceName: The Eventhubs Namespace
sharedAccessKey: The Share Access Key
sharedAccessName: The Share Access Name
sink:
ref:
kind: KafkaTopic
apiVersion: kafka.strimzi.io/v1beta1
name: my-topic
Prerequisites
-
You’ve installed Strimzi.
-
You’ve created a topic named
my-topic
in the current namespace. -
You have Camel K installed on the cluster.
Procedure for using the cluster CLI
-
Save the
azure-eventhubs-source-binding.yaml
file to your local drive, and then edit it as needed for your configuration. -
Run the source by using the following command:
kubectl apply -f azure-eventhubs-source-binding.yaml
Procedure for using the Kamel CLI
Configure and run the source by using the following command:
kamel bind azure-eventhubs-source -p "source.blobAccessKey=The Azure Storage Blob Access Key" -p "source.blobAccountName=The Azure Storage Blob Account Name" -p "source.blobContainerName=The Azure Storage Blob Container Name" -p "source.eventhubName=The Eventhubs Name" -p "source.namespaceName=The Eventhubs Namespace" -p "source.sharedAccessKey=The Share Access Key" -p "source.sharedAccessName=The Share Access Name" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
This command creates the KameletBinding in the current namespace on the cluster.