Interface OrderedKeyUberSerde<T>

All Superinterfaces:

AutoCloseable, Closeable, org.apache.kafka.common.serialization.Deserializer<org.apache.kafka.common.utils.Bytes>, 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 Subinterfaces:

OrderedKeyPrefixedSerde<E,T>

All Known Implementing Classes:

OrderedKeyPrefixedProtoSerde, OrderedKeyProtoSerde, OrderedKeyUberSerdeDelegate

public interface OrderedKeyUberSerde<T>
extends UberSerde<org.apache.kafka.common.utils.Bytes>

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
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)

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

deserialize, deserialize, deserialize

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

prefixKeySerde

OrderedKeyUberSerde<T> prefixKeySerde(int numFields)

numFields

int numFields()

key

org.apache.kafka.common.utils.Bytes key(T message)

toProto

T toProto(org.apache.kafka.common.utils.Bytes key)

toHexString

String toHexString(org.apache.kafka.common.utils.Bytes key)