Azure Kafka through Eventhubs with Azure Schema Registry Sink
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Stable"
Send data to Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
Configuration Options
The following table summarizes the configuration options available for the kafka-azure-schema-registry-sink
Kamelet:
Property | Name | Description | Type | Default | Example |
---|---|---|---|---|---|
Azure Schema Registry URL | Required The Apicurio Schema Registry URL. | string | |||
Bootstrap Servers | Required Comma separated list of Kafka Broker URLs. | string | |||
Password | Required Password to authenticate to kafka. | string | |||
Topic Names | Required Comma separated list of Kafka topic names. | string | |||
SASL Mechanism | The Simple Authentication and Security Layer (SASL) Mechanism used. | string | PLAIN | ||
Security Protocol | Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported. | string | SASL_SSL | ||
Specific Avro Value Type | The Specific Type Avro will have to deal with. | string | com.example.Order | ||
Value Deserializer | Deserializer class for value that implements the Deserializer interface. | string | com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroSerializer |
Dependencies
At runtime, the kafka-azure-schema-registry-sink
Kamelet relies upon the presence of the following dependencies:
-
camel:core
-
camel:kafka
-
camel:kamelet
-
camel:azure-schema-registry
-
mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.2
-
mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.26
-
mvn:com.azure:azure-identity:1.16.2
Camel JBang usage
Prerequisites
-
You’ve installed JBang.
-
You have executed the following command:
jbang app install camel@apache/camel
Supposing you have a file named route.yaml with this content:
- route:
from:
uri: "kamelet:timer-source"
parameters:
period: 10000
message: 'test'
steps:
- to:
uri: "kamelet:kafka-azure-schema-registry-sink"
You can now run it directly through the following command
camel run route.yaml
Azure Kafka through Eventhubs with Azure Schema Registry Sink Kamelet Description
Azure Integration
This Kamelet connects to Azure Event Hubs using Kafka protocol and integrates with Azure Schema Registry for schema management. It provides a bridge between Kafka-based applications and Azure’s messaging services.
Authentication
The Kamelet uses SASL authentication with connection string-based credentials. The security protocol defaults to SASL_SSL for secure communication with Azure Event Hubs.