public interface OrderedKeyPrefixedSerde<E extends Enum,T> extends OrderedKeyUberSerde<T>
MAGIC_BYTE_ORDERED_KEY, MAGIC_BYTE_PROTOBUF, MAGIC_BYTE_STRING
Modifier and Type | Method and 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) |
key, numFields, toHexString, toProto
deserialize, fromJson, serialize, toJson
deserializer, serializer
E prefix()
E extractPrefix(org.apache.kafka.common.utils.Bytes key)
OrderedKeyPrefixedSerde<E,T> prefixKeySerde(int numFields)
prefixKeySerde
in interface OrderedKeyUberSerde<T>