Package io.confluent.kafka.schemaregistry

Class AbstractSchemaProvider

java.lang.Object

io.confluent.kafka.schemaregistry.AbstractSchemaProvider

All Implemented Interfaces:

SchemaProvider, org.apache.kafka.common.Configurable

Direct Known Subclasses:

AvroSchemaProvider

public abstract class AbstractSchemaProvider
extends Object
implements SchemaProvider

Field Summary

Fields

Modifier and Type	Field	Description
static final String	REFERENCE_VERSIONS_STRICT_CONFIG

Fields inherited from interface io.confluent.kafka.schemaregistry.SchemaProvider

SCHEMA_PROVIDERS_PREFIX, SCHEMA_VERSION_FETCHER_CONFIG

Constructor Summary

Constructors

Constructor	Description
AbstractSchemaProvider()

Method Summary

Modifier and Type	Method	Description
protected static boolean	canLookupIgnoringVersion(ParsedSchema current, ParsedSchema prev)
void	configure(Map<String,?> configs)
protected static String	getConfluentVersion(Metadata metadata)
protected static Integer	getConfluentVersionNumber(Metadata metadata)
protected static boolean	hasLatestVersion(List<SchemaReference> refs)
protected static List<SchemaReference>	replaceLatestVersion(List<SchemaReference> refs, SchemaVersionFetcher fetcher)
protected Map<String,String>	resolveReferences(Schema schema)
protected Map<String,String>	resolveReferences(Schema schema, boolean validateAsNew)
SchemaVersionFetcher	schemaVersionFetcher()

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.SchemaProvider

parseSchema, parseSchema, parseSchema, parseSchema, parseSchema, parseSchemaOrElseThrow, schemaType

Field Details

REFERENCE_VERSIONS_STRICT_CONFIG

public static final String REFERENCE_VERSIONS_STRICT_CONFIG

See Also:

• Constant Field Values

Constructor Details

AbstractSchemaProvider

public AbstractSchemaProvider()

Method Details

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

Specified by:

configure in interface SchemaProvider

schemaVersionFetcher

public SchemaVersionFetcher schemaVersionFetcher()

resolveReferences

protected Map<String,String> resolveReferences(Schema schema)

resolveReferences

protected Map<String,String> resolveReferences(Schema schema,
 boolean validateAsNew)

canLookupIgnoringVersion

protected static boolean canLookupIgnoringVersion(ParsedSchema current,
 ParsedSchema prev)

hasLatestVersion

protected static boolean hasLatestVersion(List<SchemaReference> refs)

replaceLatestVersion

protected static List<SchemaReference> replaceLatestVersion(List<SchemaReference> refs,
 SchemaVersionFetcher fetcher)

getConfluentVersionNumber

protected static Integer getConfluentVersionNumber(Metadata metadata)

getConfluentVersion

protected static String getConfluentVersion(Metadata metadata)