Package org.springframework.cloud.stream.schema.registry.client

Interface SchemaRegistryClient

All Known Implementing Classes:

CachingRegistryClient, ConfluentSchemaRegistryClient, DefaultSchemaRegistryClient

public interface SchemaRegistryClient

Author:

Vinicius Carvalho, Marius Bogoevici

Method Summary

Modifier and Type	Method	Description
String	fetch(int id)	Retrieves a schema by its identifier.
String	fetch(SchemaReference schemaReference)	Retrieves a schema by its reference (subject and version).
SchemaRegistrationResponse	register(String subject, String format, String schema)	Registers a schema with the remote repository returning the unique identifier associated with this schema.

Method Details

register

SchemaRegistrationResponse register(String subject,
 String format,
 String schema)

Registers a schema with the remote repository returning the unique identifier associated with this schema.

Parameters:

subject - the full name of the schema

format - format of the schema

schema - string representation of the schema

Returns:

a SchemaRegistrationResponse representing the result of the operation

fetch

String fetch(SchemaReference schemaReference)

Retrieves a schema by its reference (subject and version).

Parameters:

schemaReference - a SchemaReference used to identify the target schema.

Returns:

schema

fetch

String fetch(int id)

Retrieves a schema by its identifier.

Parameters:

id - the id of the target schema.

Returns:

schema