camel.apache.org/kafka-azure-schema-registry-sink
1
0
Fork 0
generated from camel.apache.org/kamelet
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Page: Home
Pages
Home
2 Home
gitea_admin edited this page 2026-03-11 14:37:51 +00:00
Table of Contents

Azure Kafka through Eventhubs with Azure Schema Registry Sink

Send data to Kafka topics on Azure Eventhubs combined with Azure Schema Registry.

The Kamelet is able to understand the following headers to be set:

  • key / ce-key: as message key

  • partition-key / ce-partitionkey: as message partition key

Both the headers are optional.

Metadata

Property Value
Type sink
Group Kafka
Namespace Kafka
Support Level Stable
Provider Apache Software Foundation

Properties

Name Type Required Default Description
topic string ✓ Comma separated list of Kafka topic names
bootstrapServers string ✓ Comma separated list of Kafka Broker URLs
securityProtocol string SASL_SSL Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported
saslMechanism string PLAIN The Simple Authentication and Security Layer (SASL) Mechanism used.
password string ✓ Password to authenticate to kafka
valueSerializer string com.microsoft.azure.schemaregistry.kafka.avro.KafkaAvroSerializer Deserializer class for value that implements the Deserializer interface.
azureRegistryUrl string ✓ The Apicurio Schema Registry URL
specificAvroValueType string The Specific Type Avro will have to deal with

Dependencies

  • camel:core
  • camel:kafka
  • camel:kamelet
  • camel:azure-schema-registry
  • mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.1
  • mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.23
  • mvn:com.azure:azure-identity:1.15.0