2 Home
gitea_admin edited this page 2026-03-11 14:37:48 +00:00

Kafka Not Secured with Apicurio Registry Sink

Send data to Kafka topics on an insecure broker with Apicurio 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
valueSerializer string io.apicurio.registry.serde.avro.AvroKafkaSerializer Serliazer class for value that implements the Serializer interface.
apicurioRegistryUrl string The Apicurio Schema Registry URL
avroDatumProvider string io.apicurio.registry.serde.avro.ReflectAvroDatumProvider How to write data with Avro

Dependencies

  • camel:core
  • camel:kamelet
  • camel:kafka
  • mvn:io.apicurio:apicurio-registry-serdes-avro-serde:2.4.14.Final