Package io.confluent.kafka.serializers.schema.id

Class ConfigSchemaIdDeserializer

java.lang.Object

io.confluent.kafka.serializers.schema.id.ConfigSchemaIdDeserializer

All Implemented Interfaces:

SchemaIdDeserializer, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class ConfigSchemaIdDeserializer
extends Object
implements SchemaIdDeserializer

A ConfigSchemaIdDeserializer returns a schema ID that is configured using the property "use.schema.id" or "use.schema.guid".

Field Summary

Fields

Modifier and Type	Field	Description
static final String	USE_SCHEMA_GUID
static final String	USE_SCHEMA_ID

Constructor Summary

Constructors

Constructor	Description
ConfigSchemaIdDeserializer()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)
ByteBuffer	deserialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId)	Deserialize the payload and set the schema identifier.

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.serializers.schema.id.SchemaIdDeserializer

close

Field Details

USE_SCHEMA_ID

public static final String USE_SCHEMA_ID

See Also:

• Constant Field Values

USE_SCHEMA_GUID

public static final String USE_SCHEMA_GUID

See Also:

• Constant Field Values

Constructor Details

ConfigSchemaIdDeserializer

public ConfigSchemaIdDeserializer()

Method Details

configure

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

Specified by:

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

Specified by:

configure in interface SchemaIdDeserializer

deserialize

public ByteBuffer deserialize(String topic,
 boolean isKey,
 org.apache.kafka.common.header.Headers headers,
 byte[] payload,
 SchemaId schemaId)
                       throws org.apache.kafka.common.errors.SerializationException

Description copied from interface: SchemaIdDeserializer

Deserialize the payload and set the schema identifier.

Specified by:

deserialize in interface SchemaIdDeserializer

Parameters:

topic - topic associated with the payload

isKey - whether this is a record key or record value

headers - headers associated with the record; may be empty.

payload - serialized payload that may include a schema identifier

schemaId - schema identifier to be modified; either the ID or the GUID should be set

Returns:

the serialized payload that does not include a schema identifier

Throws:

org.apache.kafka.common.errors.SerializationException