camel-azure-storage-blob-cdc-source-kafka-connector source configuration

Connector Description: Receive data from Azure Service Bus subscribed to Azure Eventgrid reporting events related to a Azure Storage Blob account. Connection string is the basic method for authenticating to the Azure Servicebus Queue. To use this Kamelet you’ll need to set up Events on your Azure Storage Blob account and select as an endpoint an Azure Servicebus Queue.

When using camel-azure-storage-blob-cdc-source-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:

<dependency>
  <groupId>org.apache.camel.kafkaconnector</groupId>
  <artifactId>camel-azure-storage-blob-cdc-source-kafka-connector</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel Kafka connector version -->
</dependency>

To use this source connector in Kafka connect you’ll need to set the following connector.class

connector.class=org.apache.camel.kafkaconnector.azurestorageblobcdcsource.CamelAzurestorageblobcdcsourceSourceConnector

The camel-azure-storage-blob-cdc-source source connector supports 9 options, which are listed below.

Name Description Default Priority

camel.kamelet.azure-storage-blob-cdc-source.topicOrQueueName

Required Topic Or Queue Name for the Azure Servicebus instance.

HIGH

camel.kamelet.azure-storage-blob-cdc-source.connectionString

Required Connection String for Azure Servicebus instance.

HIGH

camel.kamelet.azure-storage-blob-cdc-source.serviceBusReceiveMode

Sets the receive mode for the receiver.

"RECEIVE_AND_DELETE"

MEDIUM

camel.kamelet.azure-storage-blob-cdc-source.subscriptionName

Sets the name of the subscription in the topic to listen to. This parameter is mandatory in case of topic.

MEDIUM

camel.kamelet.azure-storage-blob-cdc-source.accountName

Required The Azure Storage Blob account name.

HIGH

camel.kamelet.azure-storage-blob-cdc-source.containerName

Required The Azure Storage Blob container name.

HIGH

camel.kamelet.azure-storage-blob-cdc-source.accessKey

Required The Azure Storage Blob access key.

HIGH

camel.kamelet.azure-storage-blob-cdc-source.credentialType

Determines the credential strategy to adopt.

"SHARED_ACCOUNT_KEY"

MEDIUM

camel.kamelet.azure-storage-blob-cdc-source.getBlob

If getBlob is enabled, then the file created in the container will be get and returned as body, if not only the event will be returned as body.

false

MEDIUM

The camel-azure-storage-blob-cdc-source source connector has no converters out of the box.

The camel-azure-storage-blob-cdc-source source connector has no transforms out of the box.

The camel-azure-storage-blob-cdc-source source connector has no aggregation strategies out of the box.

Back to top