io.confluent.kafka.schemaregistry.storage.encoder

Class KeysetWrapperSerializer

java.lang.Object

io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serializer<KeysetWrapper>

public class KeysetWrapperSerializer
extends Object
implements org.apache.kafka.common.serialization.Serializer<KeysetWrapper>

Constructor Summary

Constructors

Constructor and Description
KeysetWrapperSerializer(SchemaRegistryConfig config)

Method Summary

Modifier and Type	Method and Description
byte[]	serialize(String topic, KeysetWrapper key)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Serializer

close, configure, serialize

Constructor Detail

KeysetWrapperSerializer

public KeysetWrapperSerializer(SchemaRegistryConfig config)

Method Detail

serialize

public byte[] serialize(String topic,
                        KeysetWrapper key)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<KeysetWrapper>