io.confluent.kafka.serializers.json

Class AbstractKafkaJsonSchemaSerializer<T>

java.lang.Object

io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer<T>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

KafkaJsonSchemaSerializer

public abstract class AbstractKafkaJsonSchemaSerializer<T>
extends AbstractKafkaSchemaSerDe

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

AbstractKafkaSchemaSerDe.ExtendedSchema, AbstractKafkaSchemaSerDe.Migration, AbstractKafkaSchemaSerDe.SubjectSchema

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	autoRegisterSchema
protected boolean	failUnknownProperties
protected boolean	idCompatStrict
protected boolean	latestCompatStrict
protected boolean	normalizeSchema
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected boolean	oneofForNullables
protected boolean	propagateSchemaTags
protected List<String>	scanPackages
protected SpecificationVersion	specVersion
protected int	useSchemaId
protected boolean	validate

Fields inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

config, configOriginals, contextNameStrategy, DEFAULT_CACHE_CAPACITY, enableRuleServiceLoader, idSize, isKey, keySubjectNameStrategy, latestVersions, latestWithMetadata, MAGIC_BYTE, metadata, ruleActions, ruleExecutors, schemaRegistry, ticker, useLatestVersion, useSchemaReflection, valueSubjectNameStrategy

Constructor Summary

Constructors

Constructor and Description
AbstractKafkaJsonSchemaSerializer()

Method Summary

Modifier and Type	Method and Description
protected void	configure(KafkaJsonSchemaSerializerConfig config)
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()
protected byte[]	serializeImpl(String subject, String topic, org.apache.kafka.common.header.Headers headers, T object, JsonSchema schema)
protected byte[]	serializeImpl(String subject, T object, JsonSchema schema)
protected KafkaJsonSchemaSerializerConfig	serializerConfig(Map<String,?> props)
protected T	validateJson(T object, JsonSchema schema)

Methods inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

clearKey, close, configureClientProperties, executeMigrations, executeRules, executeRules, getById, getBySubjectAndId, getByteBuffer, getContextName, getContextName, getLatestWithMetadata, getMigrations, getOldSubjectName, getRuleActions, getRuleExecutors, getSchemaById, getSchemaBySubjectAndId, getSchemaRegistryClient, getSubjectName, isDeprecatedSubjectNameStrategy, isKey, key, latestVersionsCache, latestWithMetadataCache, lookupLatestVersion, lookupLatestVersion, lookupSchemaBySubjectAndId, postOp, register, register, register, registerWithResponse, setKey, strategyUsesSchema, ticker, toKafkaException

Methods inherited from class java.lang.Object

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

Field Detail

normalizeSchema

protected boolean normalizeSchema

autoRegisterSchema

protected boolean autoRegisterSchema

propagateSchemaTags

protected boolean propagateSchemaTags

useSchemaId

protected int useSchemaId

idCompatStrict

protected boolean idCompatStrict

latestCompatStrict

protected boolean latestCompatStrict

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

specVersion

protected SpecificationVersion specVersion

scanPackages

protected List<String> scanPackages

oneofForNullables

protected boolean oneofForNullables

failUnknownProperties

protected boolean failUnknownProperties

validate

protected boolean validate

Constructor Detail

AbstractKafkaJsonSchemaSerializer

public AbstractKafkaJsonSchemaSerializer()

Method Detail

configure

protected void configure(KafkaJsonSchemaSerializerConfig config)

serializerConfig

protected KafkaJsonSchemaSerializerConfig serializerConfig(Map<String,?> props)

objectMapper

public com.fasterxml.jackson.databind.ObjectMapper objectMapper()

serializeImpl

protected byte[] serializeImpl(String subject,
                               T object,
                               JsonSchema schema)
                        throws org.apache.kafka.common.errors.SerializationException,
                               org.apache.kafka.common.errors.InvalidConfigurationException

Throws:

org.apache.kafka.common.errors.SerializationException

org.apache.kafka.common.errors.InvalidConfigurationException

serializeImpl

protected byte[] serializeImpl(String subject,
                               String topic,
                               org.apache.kafka.common.header.Headers headers,
                               T object,
                               JsonSchema schema)
                        throws org.apache.kafka.common.errors.SerializationException,
                               org.apache.kafka.common.errors.InvalidConfigurationException

Throws:

org.apache.kafka.common.errors.SerializationException

org.apache.kafka.common.errors.InvalidConfigurationException

validateJson

protected T validateJson(T object,
                         JsonSchema schema)
                  throws org.apache.kafka.common.errors.SerializationException

Throws:

org.apache.kafka.common.errors.SerializationException