io.confluent.serializers

Interface UberSerde<T>

All Superinterfaces:

AutoCloseable, Closeable, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>, SerdeWithJson<T>, org.apache.kafka.common.serialization.Serializer<T>

All Known Subinterfaces:

OrderedKeyPrefixedSerde<E,T>, OrderedKeyUberSerde<T>

All Known Implementing Classes:

OrderedKeyPrefixedProtoSerde, OrderedKeyProtoSerde, OrderedKeyUberSerdeDelegate, ProtoSerde, StringSerde, UberSerdes.DelegatingUberSerde

public interface UberSerde<T>
extends SerdeWithJson<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serializer<T>

Field Summary

Fields

Modifier and Type	Field and Description
static byte	MAGIC_BYTE_ORDERED_KEY
static byte	MAGIC_BYTE_PROTOBUF
static byte	MAGIC_BYTE_STRING

Method Summary

Modifier and Type	Method and Description
default void	close() Close this deserializer.
default void	configure(Map<String,?> configs, boolean isKey) Configure this class, which will configure the underlying serializer and deserializer.
Class<T>	type()

Methods inherited from interface io.confluent.serializers.SerdeWithJson

deserialize, fromJson, serialize, toJson

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

deserializer, serializer

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

deserialize, deserialize, deserialize

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

serialize, serialize

Field Detail

MAGIC_BYTE_PROTOBUF

static final byte MAGIC_BYTE_PROTOBUF

See Also:

Constant Field Values

MAGIC_BYTE_ORDERED_KEY

static final byte MAGIC_BYTE_ORDERED_KEY

See Also:

Constant Field Values

MAGIC_BYTE_STRING

static final byte MAGIC_BYTE_STRING

See Also:

Constant Field Values

Method Detail

type

Class<T> type()

configure

default void configure(Map<String,?> configs,
                       boolean isKey)

Configure this class, which will configure the underlying serializer and deserializer.

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<T>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serde<T>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<T>

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

close

default void close()

Close this deserializer.

This method must be idempotent as it may be called multiple times.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<T>

Specified by:

close in interface org.apache.kafka.common.serialization.Serde<T>

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<T>