public interface OrderedKeyUberSerde<T> extends UberSerde<org.apache.kafka.common.utils.Bytes>
MAGIC_BYTE_ORDERED_KEY, MAGIC_BYTE_PROTOBUF, MAGIC_BYTE_STRING
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.utils.Bytes |
key(T message) |
int |
numFields() |
OrderedKeyUberSerde<T> |
prefixKeySerde(int numFields) |
String |
toHexString(org.apache.kafka.common.utils.Bytes key) |
T |
toProto(org.apache.kafka.common.utils.Bytes key) |
deserialize, fromJson, serialize, toJson
deserializer, serializer
OrderedKeyUberSerde<T> prefixKeySerde(int numFields)
int numFields()
org.apache.kafka.common.utils.Bytes key(T message)
T toProto(org.apache.kafka.common.utils.Bytes key)
String toHexString(org.apache.kafka.common.utils.Bytes key)