io.confluent.kafka.schemaregistry.client

Class MockSchemaRegistryClient

java.lang.Object

io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

All Implemented Interfaces:

SchemaRegistryClient, SchemaVersionFetcher, Closeable, AutoCloseable

public class MockSchemaRegistryClient
extends Object
implements SchemaRegistryClient

Mock implementation of SchemaRegistryClient that can be used for tests. This version is NOT thread safe. Schema data is stored in memory and is not persistent or shared across instances.

Constructor Summary

Constructors

Constructor and Description
MockSchemaRegistryClient()
MockSchemaRegistryClient(List<SchemaProvider> providers)

Method Summary

Modifier and Type	Method and Description
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>	getAllContexts()
Collection<String>	getAllSubjects()
Collection<String>	getAllSubjectsById(int id)
Collection<String>	getAllSubjectsByPrefix(String subjectPrefix)
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)
SchemaMetadata	getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
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()
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, deleteConfig, deleteMode, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getAllSubjects, getAllVersions, getById, getByID, getBySubjectAndId, getBySubjectAndID, getCompatibility, getCompatibility, getConfig, getId, getSchemaRegistryServerVersion, getVersion, parseSchema, register, register, registerWithResponse, tenant, testCompatibility, testCompatibilityVerbose, ticker, updateCompatibility

Constructor Detail

MockSchemaRegistryClient

public MockSchemaRegistryClient()

MockSchemaRegistryClient

public MockSchemaRegistryClient(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

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 RestClientException

Specified by:

registerWithResponse in interface SchemaRegistryClient

Throws:

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)

Specified by:

getAllSubjectsById in interface SchemaRegistryClient

getAllVersionsById

public Collection<SubjectVersion> getAllVersionsById(int id)

Specified by:

getAllVersionsById in interface SchemaRegistryClient

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 RestClientException

Specified by:

getSchemaMetadata in interface SchemaRegistryClient

Throws:

RestClientException

getLatestSchemaMetadata

public SchemaMetadata getLatestSchemaMetadata(String subject)
                                       throws IOException,
                                              RestClientException

Specified by:

getLatestSchemaMetadata in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getLatestWithMetadata

public SchemaMetadata getLatestWithMetadata(String subject,
                                            Map<String,String> metadata,
                                            boolean lookupDeletedSchema)
                                     throws IOException,
                                            RestClientException

Specified by:

getLatestWithMetadata 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

getAllVersions

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

Specified by:

getAllVersions 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

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

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

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

getAllContexts

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

Specified by:

getAllContexts in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getSchemaRegistryDeployment

public SchemaRegistryDeployment getSchemaRegistryDeployment()
                                                     throws IOException,
                                                            RestClientException

Specified by:

getSchemaRegistryDeployment in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getAllSubjects

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

Specified by:

getAllSubjects in interface SchemaRegistryClient

Throws:

IOException

RestClientException

getAllSubjectsByPrefix

public Collection<String> getAllSubjectsByPrefix(String subjectPrefix)
                                          throws IOException,
                                                 RestClientException

Specified by:

getAllSubjectsByPrefix in interface SchemaRegistryClient

Throws:

IOException

RestClientException

reset

public void reset()

Specified by:

reset in interface SchemaRegistryClient