io.confluent.serializers

Class OrderedKeyUberSerdeDelegate<T>

java.lang.Object

io.confluent.serializers.OrderedKeyUberSerdeDelegate<T>

All Implemented Interfaces:

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 OrderedKeyUberSerdeDelegate<T>
extends Object
implements OrderedKeyUberSerde<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 and Description
OrderedKeyUberSerdeDelegate(OrderedKeyUberSerde<T> delegate)

Method Summary

Modifier and Type	Method and Description
void	close() Close this deserializer.
void	configure(Map<String,?> map, boolean b) Configure this class, which will configure the underlying serializer and deserializer.
org.apache.kafka.common.utils.Bytes	deserialize(byte[] bytes)
org.apache.kafka.common.utils.Bytes	deserialize(String s, byte[] bytes)
org.apache.kafka.common.serialization.Deserializer<org.apache.kafka.common.utils.Bytes>	deserializer()
byte[]	fromJson(String json)
org.apache.kafka.common.utils.Bytes	key(T message)
int	numFields()
OrderedKeyUberSerde<T>	prefixKeySerde(int numFields)
byte[]	serialize(org.apache.kafka.common.utils.Bytes message)
byte[]	serialize(String s, org.apache.kafka.common.utils.Bytes bytes)
org.apache.kafka.common.serialization.Serializer<org.apache.kafka.common.utils.Bytes>	serializer()
String	toHexString(org.apache.kafka.common.utils.Bytes key)
String	toJson(org.apache.kafka.common.utils.Bytes message)
T	toProto(org.apache.kafka.common.utils.Bytes key)
Class<org.apache.kafka.common.utils.Bytes>	type()

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

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

serialize

Constructor Detail

OrderedKeyUberSerdeDelegate

public OrderedKeyUberSerdeDelegate(OrderedKeyUberSerde<T> delegate)

Method Detail

prefixKeySerde

public OrderedKeyUberSerde<T> prefixKeySerde(int numFields)

Specified by:

prefixKeySerde in interface OrderedKeyUberSerde<T>

numFields

public int numFields()

Specified by:

numFields in interface OrderedKeyUberSerde<T>

key

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

Specified by:

key in interface OrderedKeyUberSerde<T>

toProto

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

Specified by:

toProto in interface OrderedKeyUberSerde<T>

toHexString

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

Specified by:

toHexString in interface OrderedKeyUberSerde<T>

type

public Class<org.apache.kafka.common.utils.Bytes> type()

Specified by:

type in interface UberSerde<org.apache.kafka.common.utils.Bytes>

deserialize

public org.apache.kafka.common.utils.Bytes deserialize(byte[] bytes)

Specified by:

deserialize in interface SerdeWithJson<org.apache.kafka.common.utils.Bytes>

deserialize

public org.apache.kafka.common.utils.Bytes deserialize(String s,
                                                       byte[] bytes)

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<org.apache.kafka.common.utils.Bytes>

serialize

public byte[] serialize(org.apache.kafka.common.utils.Bytes message)

Specified by:

serialize in interface SerdeWithJson<org.apache.kafka.common.utils.Bytes>

serialize

public byte[] serialize(String s,
                        org.apache.kafka.common.utils.Bytes bytes)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<org.apache.kafka.common.utils.Bytes>

fromJson

public byte[] fromJson(String json)

Specified by:

fromJson in interface SerdeWithJson<org.apache.kafka.common.utils.Bytes>

toJson

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

Specified by:

toJson in interface SerdeWithJson<org.apache.kafka.common.utils.Bytes>

configure

public void configure(Map<String,?> map,
                      boolean b)

Description copied from interface: UberSerde

Configure this class, which will configure the underlying serializer and deserializer.

Specified by:

configure in interface UberSerde<org.apache.kafka.common.utils.Bytes>

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<org.apache.kafka.common.utils.Bytes>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serde<org.apache.kafka.common.utils.Bytes>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<org.apache.kafka.common.utils.Bytes>

Parameters:

map - configs in key/value pairs

b - whether is for key or value

close

public void close()

Description copied from interface: UberSerde

Close this deserializer.

This method must be idempotent as it may be called multiple times.

Specified by:

close in interface UberSerde<org.apache.kafka.common.utils.Bytes>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<org.apache.kafka.common.utils.Bytes>

Specified by:

close in interface org.apache.kafka.common.serialization.Serde<org.apache.kafka.common.utils.Bytes>

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<org.apache.kafka.common.utils.Bytes>

serializer

public org.apache.kafka.common.serialization.Serializer<org.apache.kafka.common.utils.Bytes> serializer()

Specified by:

serializer in interface org.apache.kafka.common.serialization.Serde<org.apache.kafka.common.utils.Bytes>

deserializer

public org.apache.kafka.common.serialization.Deserializer<org.apache.kafka.common.utils.Bytes> deserializer()

Specified by:

deserializer in interface org.apache.kafka.common.serialization.Serde<org.apache.kafka.common.utils.Bytes>