Package io.confluent.kafka.schemaregistry.storage.serialization

Class SchemaRegistrySerializer

java.lang.Object

io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer

All Implemented Interfaces:

Serializer<SchemaRegistryKey,SchemaRegistryValue>, Closeable, Serializable, AutoCloseable, org.apache.kafka.common.Configurable

public class SchemaRegistrySerializer
extends Object
implements Serializer<SchemaRegistryKey,SchemaRegistryValue>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SchemaRegistrySerializer()

Method Summary

Modifier and Type	Method	Description
void	close()	Close this serializer
void	configure(Map<String,?> stringMap)
SchemaRegistryKey	deserializeKey(byte[] key)
SchemaRegistryValue	deserializeValue(SchemaRegistryKey key, byte[] value)
byte[]	serializeKey(SchemaRegistryKey key)
byte[]	serializeValue(SchemaRegistryValue value)

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaRegistrySerializer

public SchemaRegistrySerializer()

Method Details

serializeKey

public byte[] serializeKey(SchemaRegistryKey key)
                    throws SerializationException

Specified by:

serializeKey in interface Serializer<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

key - Typed key

Returns:

bytes of the serialized key

Throws:

SerializationException

serializeValue

public byte[] serializeValue(SchemaRegistryValue value)
                      throws SerializationException

Specified by:

serializeValue in interface Serializer<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

value - Typed value

Returns:

bytes of the serialized value

Throws:

SerializationException

deserializeKey

public SchemaRegistryKey deserializeKey(byte[] key)
                                 throws SerializationException

Specified by:

deserializeKey in interface Serializer<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

key - Bytes of the serialized key

Returns:

Typed deserialized key

Throws:

SerializationException

deserializeValue

public SchemaRegistryValue deserializeValue(SchemaRegistryKey key,
 byte[] value)
                                     throws SerializationException

Specified by:

deserializeValue in interface Serializer<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

key - Typed key corresponding to this value

value - Bytes of the serialized value

Returns:

Typed deserialized value. Must be one of ConfigValue or ModeValue or SchemaValue or DeleteSubjectValue or ClearSubjectValue

Throws:

SerializationException

close

public void close()

Description copied from interface: Serializer

Close this serializer

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Serializer<SchemaRegistryKey,SchemaRegistryValue>

configure

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

Specified by:

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