io.confluent.kafka.schemaregistry.rest.client

Class LocalSchemaRegistryClient

java.lang.Object

io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient

All Implemented Interfaces:

SchemaRegistryClient, SchemaVersionFetcher, Closeable, AutoCloseable

public class LocalSchemaRegistryClient
extends Object
implements SchemaRegistryClient

Local implementation of SchemaRegistryClient that can be used without going through HTTP.

Constructor Summary

Constructors

Constructor and Description
LocalSchemaRegistryClient(KafkaSchemaRegistry schemaRegistry)
LocalSchemaRegistryClient(KafkaSchemaRegistry schemaRegistry, List<SchemaProvider> providers)

Method Summary

Modifier and Type	Method and Description
void	deleteConfig(String subject)
Integer	deleteSchemaVersion(Map<String,String> requestProperties, String subject, String version, boolean isPermanent)
Integer	deleteSchemaVersion(String subject, String version, boolean isPermanent)
List<Integer>	deleteSubject(Map<String,String> requestProperties, String subject, boolean isPermanent)
List<Integer>	deleteSubject(String subject, boolean isPermanent)
Collection<String>	getAllSubjects()
Collection<String>	getAllSubjectsById(int id)
List<Integer>	getAllVersions(String subject)
Collection<SubjectVersion>	getAllVersionsById(int id)
Schema	getByVersion(String subject, int version, boolean lookupDeletedSchema)
Config	getConfig(String subject)
int	getId(String subject, ParsedSchema schema)
int	getId(String subject, ParsedSchema schema, boolean normalize)
SchemaMetadata	getLatestSchemaMetadata(String subject)
String	getMode()
String	getMode(String subject)
ParsedSchema	getSchemaById(int id)
ParsedSchema	getSchemaBySubjectAndId(String subject, int id)
SchemaMetadata	getSchemaMetadata(String subject, int version)
SchemaMetadata	getSchemaMetadata(String subject, int version, boolean lookupDeletedSchema)
SchemaRegistryDeployment	getSchemaRegistryDeployment()
SchemaRegistryServerVersion	getSchemaRegistryServerVersion()
List<ParsedSchema>	getSchemas(String subjectPrefix, boolean lookupDeletedSchema, boolean latestOnly)
int	getVersion(String subject, ParsedSchema schema)
int	getVersion(String subject, ParsedSchema schema, boolean normalize)
Optional<ParsedSchema>	parseSchema(Schema schema)
Optional<ParsedSchema>	parseSchema(String schemaType, String schemaString, List<SchemaReference> references)
int	register(String subject, ParsedSchema schema)
int	register(String subject, ParsedSchema schema, boolean normalize)
int	register(String subject, ParsedSchema schema, int version, int id)
RegisterSchemaResponse	registerWithResponse(String subject, ParsedSchema schema, boolean normalize, boolean propagateSchemaTags)
void	reset()
String	setMode(String mode)
String	setMode(String mode, String subject)
String	setMode(String mode, String subject, boolean force)
boolean	testCompatibility(String subject, ParsedSchema newSchema)
List<String>	testCompatibilityVerbose(String subject, ParsedSchema newSchema)
Config	updateConfig(String subject, Config config)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

close, deleteCompatibility, deleteMode, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getAllContexts, getAllSubjects, getAllSubjectsByPrefix, getAllVersions, getById, getByID, getBySubjectAndId, getBySubjectAndID, getCompatibility, getId, getLatestWithMetadata, getVersion, parseSchema, register, register, registerWithResponse, tenant, testCompatibility, testCompatibilityVerbose, ticker, updateCompatibility

Constructor Detail

LocalSchemaRegistryClient

public LocalSchemaRegistryClient(KafkaSchemaRegistry schemaRegistry)

LocalSchemaRegistryClient

public LocalSchemaRegistryClient(KafkaSchemaRegistry schemaRegistry,
                                 List<SchemaProvider> providers)

Method Detail

parseSchema

public Optional<ParsedSchema> parseSchema(String schemaType,
                                          String schemaString,
                                          List<SchemaReference> references)

Specified by:

parseSchema in interface SchemaRegistryClient

parseSchema

public Optional<ParsedSchema> parseSchema(Schema schema)

Specified by:

parseSchema in interface SchemaRegistryClient

getAllVersions

public List<Integer> getAllVersions(String subject)
                             throws IOException,
                                    RestClientException

Specified by:

getAllVersions in interface SchemaRegistryClient

Throws:

IOException

RestClientException

register

public int register(String subject,
                    ParsedSchema schema)
             throws IOException,
                    RestClientException

Specified by:

register in interface SchemaRegistryClient

Throws:

IOException

RestClientException

register

public int register(String subject,
                    ParsedSchema schema,
                    boolean normalize)
             throws IOException,
                    RestClientException

Specified by:

register in interface SchemaRegistryClient

Throws:

IOException

RestClientException

register

public int register(String subject,
                    ParsedSchema schema,
                    int version,
                    int id)
             throws IOException,
                    RestClientException

Specified by:

register in interface SchemaRegistryClient

Throws:

IOException

RestClientException

registerWithResponse

public RegisterSchemaResponse registerWithResponse(String subject,
                                                   ParsedSchema schema,
                                                   boolean normalize,
                                                   boolean propagateSchemaTags)
                                            throws IOException,
                                                   RestClientException

Specified by:

registerWithResponse in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemaById

public ParsedSchema getSchemaById(int id)
                           throws IOException,
                                  RestClientException

Specified by:

getSchemaById in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemaBySubjectAndId

public ParsedSchema getSchemaBySubjectAndId(String subject,
                                            int id)
                                     throws IOException,
                                            RestClientException

Specified by:

getSchemaBySubjectAndId in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemas

public List<ParsedSchema> getSchemas(String subjectPrefix,
                                     boolean lookupDeletedSchema,
                                     boolean latestOnly)
                              throws IOException,
                                     RestClientException

Specified by:

getSchemas in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getAllSubjectsById

public Collection<String> getAllSubjectsById(int id)
                                      throws IOException,
                                             RestClientException

Specified by:

getAllSubjectsById in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getAllVersionsById

public Collection<SubjectVersion> getAllVersionsById(int id)
                                              throws IOException,
                                                     RestClientException

Specified by:

getAllVersionsById in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getByVersion

public Schema getByVersion(String subject,
                           int version,
                           boolean lookupDeletedSchema)

Specified by:

getByVersion in interface SchemaRegistryClient

Specified by:

getByVersion in interface SchemaVersionFetcher

getSchemaMetadata

public SchemaMetadata getSchemaMetadata(String subject,
                                        int version)
                                 throws IOException,
                                        RestClientException

Specified by:

getSchemaMetadata in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemaMetadata

public SchemaMetadata getSchemaMetadata(String subject,
                                        int version,
                                        boolean lookupDeletedSchema)
                                 throws IOException,
                                        RestClientException

Specified by:

getSchemaMetadata in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getLatestSchemaMetadata

public SchemaMetadata getLatestSchemaMetadata(String subject)
                                       throws IOException,
                                              RestClientException

Specified by:

getLatestSchemaMetadata in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getVersion

public int getVersion(String subject,
                      ParsedSchema schema)
               throws IOException,
                      RestClientException

Specified by:

getVersion in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getVersion

public int getVersion(String subject,
                      ParsedSchema schema,
                      boolean normalize)
               throws IOException,
                      RestClientException

Specified by:

getVersion in interface SchemaRegistryClient

Throws:

IOException

RestClientException

testCompatibility

public boolean testCompatibility(String subject,
                                 ParsedSchema newSchema)
                          throws IOException,
                                 RestClientException

Specified by:

testCompatibility in interface SchemaRegistryClient

Throws:

IOException

RestClientException

testCompatibilityVerbose

public List<String> testCompatibilityVerbose(String subject,
                                             ParsedSchema newSchema)
                                      throws IOException,
                                             RestClientException

Specified by:

testCompatibilityVerbose in interface SchemaRegistryClient

Throws:

IOException

RestClientException

updateConfig

public Config updateConfig(String subject,
                           Config config)
                    throws IOException,
                           RestClientException

Specified by:

updateConfig in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getConfig

public Config getConfig(String subject)
                 throws IOException,
                        RestClientException

Specified by:

getConfig in interface SchemaRegistryClient

Throws:

IOException

RestClientException

deleteConfig

public void deleteConfig(String subject)
                  throws IOException,
                         RestClientException

Specified by:

deleteConfig in interface SchemaRegistryClient

Throws:

IOException

RestClientException

setMode

public String setMode(String mode)
               throws IOException,
                      RestClientException

Specified by:

setMode in interface SchemaRegistryClient

Throws:

IOException

RestClientException

setMode

public String setMode(String mode,
                      String subject)
               throws IOException,
                      RestClientException

Specified by:

setMode in interface SchemaRegistryClient

Throws:

IOException

RestClientException

setMode

public String setMode(String mode,
                      String subject,
                      boolean force)
               throws IOException,
                      RestClientException

Specified by:

setMode in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getMode

public String getMode()
               throws IOException,
                      RestClientException

Specified by:

getMode in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getMode

public String getMode(String subject)
               throws IOException,
                      RestClientException

Specified by:

getMode in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getAllSubjects

public Collection<String> getAllSubjects()
                                  throws IOException,
                                         RestClientException

Specified by:

getAllSubjects in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getId

public int getId(String subject,
                 ParsedSchema schema)
          throws IOException,
                 RestClientException

Specified by:

getId in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getId

public int getId(String subject,
                 ParsedSchema schema,
                 boolean normalize)
          throws IOException,
                 RestClientException

Specified by:

getId in interface SchemaRegistryClient

Throws:

IOException

RestClientException

deleteSubject

public List<Integer> deleteSubject(String subject,
                                   boolean isPermanent)
                            throws IOException,
                                   RestClientException

Specified by:

deleteSubject in interface SchemaRegistryClient

Throws:

IOException

RestClientException

deleteSubject

public List<Integer> deleteSubject(Map<String,String> requestProperties,
                                   String subject,
                                   boolean isPermanent)
                            throws IOException,
                                   RestClientException

Specified by:

deleteSubject in interface SchemaRegistryClient

Throws:

IOException

RestClientException

deleteSchemaVersion

public Integer deleteSchemaVersion(String subject,
                                   String version,
                                   boolean isPermanent)
                            throws IOException,
                                   RestClientException

Specified by:

deleteSchemaVersion in interface SchemaRegistryClient

Throws:

IOException

RestClientException

deleteSchemaVersion

public Integer deleteSchemaVersion(Map<String,String> requestProperties,
                                   String subject,
                                   String version,
                                   boolean isPermanent)
                            throws IOException,
                                   RestClientException

Specified by:

deleteSchemaVersion in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemaRegistryDeployment

public SchemaRegistryDeployment getSchemaRegistryDeployment()
                                                     throws IOException,
                                                            RestClientException

Specified by:

getSchemaRegistryDeployment in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemaRegistryServerVersion

public SchemaRegistryServerVersion getSchemaRegistryServerVersion()
                                                           throws IOException,
                                                                  RestClientException

Specified by:

getSchemaRegistryServerVersion in interface SchemaRegistryClient

Throws:

IOException

RestClientException

reset

public void reset()

Specified by:

reset in interface SchemaRegistryClient