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

Kafka Not Secured with Apicurio Registry Source

Receive data from Kafka topics on an insecure broker combined with Apicurio Registry.

Metadata

Property Value
Type source
Group Kafka
Namespace Kafka
Support Level Preview
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
autoCommitEnable boolean true If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer
allowManualCommit boolean false Whether to allow doing manual commits
pollOnError string ERROR_HANDLER What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP
autoOffsetReset string latest What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none
consumerGroup string A string that uniquely identifies the group of consumers to which this source belongs
deserializeHeaders boolean true When enabled the Kamelet source will deserialize all message headers to String representation.
valueDeserializer string io.apicurio.registry.serde.jsonschema.JsonSchemaKafkaDeserializer Deserializer class for value that implements the Deserializer interface.
apicurioRegistryUrl string The Apicurio Schema Registry URL
topicIsPattern boolean false Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.

Dependencies

  • camel:kafka
  • camel:core
  • camel:kamelet
  • mvn:io.quarkus:quarkus-apicurio-registry-json-schema:3.15.1