Configure ksqlDB for Avro, Protobuf, and JSON in ksqlDB for Confluent Platform

For supported Serialization Formats, ksqlDB can integrate with Confluent Schema Registry. ksqlDB automatically retrieves (reads) and registers (writes) schemas as needed, which spares you from defining columns and data types manually in CREATE statements and from manual interaction with Schema Registry. For more information, see Schema Inference.

You must configure the REST endpoint of Schema Registry by setting ksql.schema.registry.url in the ksqlDB Server configuration file (<path-to-confluent>/etc/ksqldb/ksql-server.properties). For more information, see Configure ksqlDB for Secured Confluent Schema Registry. Schema Registry is included by default with Confluent Platform.

Important

Don’t use the SET statement in the ksqlDB CLI to configure the registry endpoint.