io.confluent.kafka.schemaregistry.json

Class JsonSchemaProvider

java.lang.Object

io.confluent.kafka.schemaregistry.AbstractSchemaProvider

io.confluent.kafka.schemaregistry.json.JsonSchemaProvider

All Implemented Interfaces:

SchemaProvider, org.apache.kafka.common.Configurable

public class JsonSchemaProvider
extends AbstractSchemaProvider

Field Summary

Fields

Modifier and Type	Field and Description
static String	FETCH_REMOTE_REFS Config key (within the schema.providers. provider config map) controlling whether remote HTTP(S) schema references may be fetched.

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

SCHEMA_VERSION_FETCHER_CONFIG

Constructor Summary

Constructors

Constructor and Description
JsonSchemaProvider()

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,?> configs)
ParsedSchema	parseSchemaOrElseThrow(Schema schema, boolean isNew, boolean normalize)
String	schemaType()
protected boolean	shouldBlockRemoteRefs(Schema schema, boolean fetchRemoteRefs) Determines whether remote HTTP(S) schema-reference fetching should be blocked while loading the given schema.

Methods inherited from class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

canLookupIgnoringVersion, getConfluentVersion, getConfluentVersionNumber, hasLatestVersion, replaceLatestVersion, resolveReferences, resolveReferences, 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

Field Detail

FETCH_REMOTE_REFS

public static final String FETCH_REMOTE_REFS

Config key (within the schema.providers. provider config map) controlling whether remote HTTP(S) schema references may be fetched. The typed value is injected by the schema registry from schema.providers.json.fetch.remote.schemas (defaults to true).

See Also:

Constant Field Values

Constructor Detail

JsonSchemaProvider

public JsonSchemaProvider()

Method Detail

configure

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

Specified by:

configure in interface SchemaProvider

Specified by:

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

Overrides:

configure in class AbstractSchemaProvider

schemaType

public String schemaType()

shouldBlockRemoteRefs

protected boolean shouldBlockRemoteRefs(Schema schema,
                                        boolean fetchRemoteRefs)

Determines whether remote HTTP(S) schema-reference fetching should be blocked while loading the given schema. Subclasses may override to apply a narrower policy (e.g. only blocking new schema registrations) than the default of blocking all fetches once disabled.

parseSchemaOrElseThrow

public ParsedSchema parseSchemaOrElseThrow(Schema schema,
                                           boolean isNew,
                                           boolean normalize)