Schema Registry catalog

The Schema Registry catalog allows you to access Kafka topics with registered schemas as Flink SQL tables. You can add Schema Registry as a catalog in Flink SQL by adding the dependency to your project, registering it in Java, and enabling it in the custom environment file.

Each Kafka topic will be mapped to a table with TableSchema that matches the Avro schema.

Maven Dependency
The following example shows how to register and use the Schema Registry catalog from Java:
SchemaRegistryClient client = new SchemaRegistryClient(

Map<String, String> connectorProps = new Kafka()

   "registry", new ClouderaRegistryCatalog("registry", client, connectorProps)