Package com.linkedin.venice.pubsub.api

Class PubSubMessageDeserializer

java.lang.Object

com.linkedin.venice.pubsub.api.PubSubMessageDeserializer

public class PubSubMessageDeserializer
extends Object

The class for deserializing messages from the pubsub specific message format to PubSubMessage

Constructor Summary

Constructors

Constructor	Description
PubSubMessageDeserializer(KafkaValueSerializer valueSerializer, ObjectPool<KafkaMessageEnvelope> putEnvelopePool, ObjectPool<KafkaMessageEnvelope> updateEnvelopePool)

Method Summary

Modifier and Type	Method	Description
void	close()
PubSubMessage<KafkaKey,KafkaMessageEnvelope,Long>	deserialize(PubSubTopicPartition topicPartition, byte[] keyBytes, byte[] valueBytes, PubSubMessageHeaders headers, Long position, Long timestamp)	Deserialize a message from the pubsub specific message format to PubSubMessage.
static PubSubMessageDeserializer	getInstance()
KafkaValueSerializer	getValueSerializer()

Methods inherited from class java.lang.Object

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

Constructor Details

PubSubMessageDeserializer

public PubSubMessageDeserializer(KafkaValueSerializer valueSerializer,
 ObjectPool<KafkaMessageEnvelope> putEnvelopePool,
 ObjectPool<KafkaMessageEnvelope> updateEnvelopePool)

Method Details

deserialize

public PubSubMessage<KafkaKey,KafkaMessageEnvelope,Long> deserialize(PubSubTopicPartition topicPartition,
 byte[] keyBytes,
 byte[] valueBytes,
 PubSubMessageHeaders headers,
 Long position,
 Long timestamp)

Deserialize a message from the pubsub specific message format to PubSubMessage.

Parameters:

topicPartition - the topic partition from which the message was read

keyBytes - the key bytes of the message

valueBytes - the value bytes of the message

headers - the headers of the message

position - the position of the message in the topic partition

timestamp - the timestamp of the message

Returns:

the deserialized PubSubMessage

close

public void close()

getValueSerializer

public KafkaValueSerializer getValueSerializer()

getInstance

public static PubSubMessageDeserializer getInstance()