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:
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