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>

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

Interface OrderedKeyPrefixedSerde<E extends Enum, T>

Field Summary