Schema registry is recommended if you plan to use Avro for a data format because it can help you with:
- and schema evolution.
with schema knowledge
- Localhost: Start the Schema Registry in its own terminal.
docker run -d \ --net=host \ --name=schema-registry \ -e SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL=localhost:32181 \ -e SCHEMA_REGISTRY_HOST_NAME=localhost \ -e SCHEMA_REGISTRY_LISTENERS=http://localhost:8081 \ confluentinc/cp-schema-registry:4.0.0
Produce with Schema registry
create data with a schema. See Kafka - kafka-avro-console-producer utility
You can change the compatibility level of Schema Registry to allow incompatible schemas or other compatibility levels. There are two ways to do this:
- Set the compatibility level for subjects which are used by the connector using PUT /config/(string: subject).
- Configure the Schema Registry to use other schema compatibility level by setting avro.compatibility.level in Schema Registry. Note that this is a global setting that applies to all schemas in the Schema Registry.
The subjects have format of topic-key and topic-value where the topic is determined by topic.prefix config and table name.