Package io.confluent.serializers

Class OrderedKeyPrefixedProtoSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>

java.lang.Object

io.confluent.serializers.OrderedKeyProtoSerde<T>

io.confluent.serializers.OrderedKeyPrefixedProtoSerde<E,T>

All Implemented Interfaces:

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

public class OrderedKeyPrefixedProtoSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>
extends OrderedKeyProtoSerde<T>
implements OrderedKeyPrefixedSerde<E,T>

Field Summary

Fields inherited from interface io.confluent.serializers.UberSerde

MAGIC_BYTE_ORDERED_KEY, MAGIC_BYTE_PROTOBUF, MAGIC_BYTE_STRING

Constructor Summary

Constructors

Constructor	Description
OrderedKeyPrefixedProtoSerde(E prefix, T instance, com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap)
OrderedKeyPrefixedProtoSerde(E prefix, T instance, com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap, int numFields)

Method Summary

Modifier and Type	Method	Description
static <E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum, T extends com.google.protobuf.Message> OrderedKeyPrefixedSerde<E,T>	create(E prefix, T instance, com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<Integer>> fieldIdsMap)
E	extractPrefix(org.apache.kafka.common.utils.Bytes key)	Extracts the prefix from the byte array of the key
byte[]	fromJson(String json)
org.apache.kafka.common.utils.Bytes	key(T message)
E	prefix()	Returns the prefix used for serializing keys
OrderedKeyPrefixedSerde<E,T>	prefixKeySerde(int numFields)
String	toJson(org.apache.kafka.common.utils.Bytes key)
T	toProto(org.apache.kafka.common.utils.Bytes key)

Methods inherited from class io.confluent.serializers.OrderedKeyProtoSerde

close, configure, create, deserialize, deserialize, deserializer, encodeEnum, getMaxSerializedBytes, jsonToProto, numFields, protoToJson, readMagicByte, readProto, serialize, serialize, serializer, toHexString, type, writeMagicByte, writeProto

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

deserialize, deserialize, deserialize

Methods inherited from interface io.confluent.serializers.OrderedKeyUberSerde

numFields, toHexString

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

deserializer, serializer

Methods inherited from interface io.confluent.serializers.SerdeWithJson

deserialize, serialize

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

serialize, serialize

Methods inherited from interface io.confluent.serializers.UberSerde

close, configure, type

Constructor Details

OrderedKeyPrefixedProtoSerde

public OrderedKeyPrefixedProtoSerde(E prefix,
 T instance,
 com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap)

OrderedKeyPrefixedProtoSerde

public OrderedKeyPrefixedProtoSerde(E prefix,
 T instance,
 com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap,
 int numFields)

Method Details

create

public static <E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,
T extends com.google.protobuf.Message>
OrderedKeyPrefixedSerde<E,T> create(E prefix,
 T instance,
 com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<Integer>> fieldIdsMap)

prefix

public E prefix()

Description copied from interface: OrderedKeyPrefixedSerde

Returns the prefix used for serializing keys

Specified by:

prefix in interface OrderedKeyPrefixedSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>

extractPrefix

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

Description copied from interface: OrderedKeyPrefixedSerde

Extracts the prefix from the byte array of the key

Specified by:

extractPrefix in interface OrderedKeyPrefixedSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>

prefixKeySerde

public OrderedKeyPrefixedSerde<E,T> prefixKeySerde(int numFields)

Specified by:

prefixKeySerde in interface OrderedKeyPrefixedSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>

Specified by:

prefixKeySerde in interface OrderedKeyUberSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum>

Overrides:

prefixKeySerde in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>

key

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

Specified by:

key in interface OrderedKeyUberSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum>

Overrides:

key in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>

toProto

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

Specified by:

toProto in interface OrderedKeyUberSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum>

Overrides:

toProto in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>

fromJson

public byte[] fromJson(String json)

Specified by:

fromJson in interface SerdeWithJson<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum>

Overrides:

fromJson in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>

toJson

public String toJson(org.apache.kafka.common.utils.Bytes key)

Specified by:

toJson in interface SerdeWithJson<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum>

Overrides:

toJson in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>