Package io.confluent.serializers

Interface OrderedKeyPrefixedSerde<E extends Enum,T>

All Superinterfaces:

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

All Known Implementing Classes:

OrderedKeyPrefixedProtoSerde

public interface OrderedKeyPrefixedSerde<E extends Enum,T>
extends OrderedKeyUberSerde<T>

Field Summary

Fields inherited from interface io.confluent.serializers.UberSerde

MAGIC_BYTE_ORDERED_KEY, MAGIC_BYTE_PROTOBUF, MAGIC_BYTE_STRING

Method Summary

Modifier and Type	Method	Description
E	extractPrefix(org.apache.kafka.common.utils.Bytes key)	Extracts the prefix from the byte array of the key
E	prefix()	Returns the prefix used for serializing keys
OrderedKeyPrefixedSerde<E,T>	prefixKeySerde(int numFields)

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

deserialize, deserialize, deserialize

Methods inherited from interface io.confluent.serializers.OrderedKeyUberSerde

key, numFields, toHexString, toProto

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

deserializer, serializer

Methods inherited from interface io.confluent.serializers.SerdeWithJson

deserialize, fromJson, serialize, toJson

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

serialize, serialize

Methods inherited from interface io.confluent.serializers.UberSerde

close, configure, type

Method Details

prefix

E prefix()

Returns the prefix used for serializing keys

extractPrefix

E extractPrefix(org.apache.kafka.common.utils.Bytes key)

Extracts the prefix from the byte array of the key

prefixKeySerde

OrderedKeyPrefixedSerde<E,T> prefixKeySerde(int numFields)

Specified by:

prefixKeySerde in interface OrderedKeyUberSerde<E extends Enum>