Comment on page
CREATE SCHEMA_REGISTRY
CREATE SCHEMA_REGISTRY
schema_registry_name
WITH (schema_registry_parameter = value [, ... ]);
Schema Registries are useful for storing and managing the many schemas that may define a user's data streams. These schemas are necessary for a system to marshal and unmarshal records and make sure the native data format matches the intended format. After creating a Schema Registry, look at how to UPDATE STORE to attach the Schema Registry to a Store. The Schema Registry that is created will be accessible to the user who created it and anyone who has been given permissions.
Schema Registry is required for working with Avro data
Currently supported Schema Registries are Confluent Cloud and Confluent Platform
Specifies the name of the new Schema Registry. For case-sensitive names, the name must be wrapped in double quotes, otherwise, the lowercased name will be used.
This clause specifies Schema Registry parameters; see Schema Registry Parameters below for more information.
Parameter Name | Description |
|---|---|
type | Required. Type of Schema Registry.
Type: SCHEMA_REGISTRY_TYPE
Valid values: CONFLUENT, CONFLUENT_CLOUD |
access_region | Required, unless specified in properties.file. Region the Schema Registry resides in.
Type: String
Valid values: See LIST REGIONS |
uris | Required, unless specified in properties.file. List of comma separated host:port URIs to connect to the Schema Registry.
Type: String
Valid values: Valid URI that corresponds with the Schema Registry. |
properties.file | Optional. The file path to a yaml file containing other Schema Registry parameters.
Default value: None
Type: String
Valid values: File path in current user's filesystem |
Parameter Name | Description |
|---|---|
confluent_cloud.key | Optional. Credentials key for the Confluent Cloud Schema Registry.
Default: None
Type: String
Valid values: The key corresponding with the credential key pair associated with the Schema Registry. |
confluent_cloud.secret | Optional. Credentials secret for the Confluent Cloud Schema Registry.
Default: None
Type: String
Valid values: The secret corresponding with the credential key pair associated with the Schema Registry. |
Parameter Name | Description |
|---|---|
confluent.username | Optional. Login username for the Confluent Platform Schema Registry.
Default: None
Type: String |
confluent.password | Optional. Login password for the Confluent Platform Schema Registry.
Default: None
Type: String |
tls.client.cert_file | Optional. File path to client certificate for mutual TLS authentication in PEM format.
Default: None
Type: String |
tls.client.key_file | Optional. File path to client certificate key for mutual TLS authentication in PEM format.
Default: None
Type: String |
The following is an example statement that creates a new
CONFLUENT_CLOUD Schema Registry named ConfluentCloudSR:CREATE SCHEMA_REGISTRY "ConfluentCloudSR" WITH (
'type' = CONFLUENT_CLOUD,
'access_region' = "AWS us-east-2",
'uris' = 'https://abcd-efghi.us-east-2.aws.confluent.cloud',
'confluent_cloud.key' = 'fake_key',
'confluent_cloud.secret' = 'fake_secret'
);
The following is an example statement that creates a new
CONFLUENT Schema Registry named ConfluentPlatformSR:CREATE SCHEMA_REGISTRY "ConfluentPlatformSR" WITH (
'type' = CONFLUENT,
'access_region' = "AWS us-east-2",
'uris' = 'https://url.to.schema.registry.listener:8081',
'confluent.username' = 'fake_username',
'confluent.secret' = 'fake_password',
'tls.client.cert_file' = '/path/to/tls/client_cert_file',
'tls.client.key_file' = '/path/to/tls_key'
);
The following creates a new
CONFLUENT_CLOUD Schema Registry named ConfluentCloudSR:CREATE SCHEMA_REGISTRY "ConfluentCloudSR" WITH (
'type' = CONFLUENT_CLOUD,
'properties.file' = '/User/user1/schema_registry/cc/properties.yaml'
);
$ cat /User/user1/schema_registry/cc/properties.yaml
access_region: "AWS us-east-2"
uris: "https://abcd-efghi.us-east-2.aws.confluent.cloud"
confluent_cloud.key: "SR_KEY"
confluent_cloud.secret: "SR_SECRET"
Last modified 1mo ago