Package com.linkedin.venice.pubsub.adapter

Class SimplePubSubProduceResultImpl

java.lang.Object

com.linkedin.venice.pubsub.adapter.SimplePubSubProduceResultImpl

All Implemented Interfaces:

PubSubProduceResult

Direct Known Subclasses:

ApacheKafkaProduceResult

public class SimplePubSubProduceResultImpl
extends Object
implements PubSubProduceResult

A simple implementation of PubSubProduceResult interface for testing purposes.

Constructor Summary

Constructors

Constructor	Description
SimplePubSubProduceResultImpl(String topic, int partition, PubSubPosition pubSubPosition, int serializedSize)

Method Summary

Modifier and Type	Method	Description
int	getPartition()	The partition the record was sent to
PubSubPosition	getPubSubPosition()	The position of the record in the topic/partition.
int	getSerializedSize()	Sum of the size of the serialized, uncompressed key and value in bytes.
String	getTopic()	The topic the record was appended to
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

SimplePubSubProduceResultImpl

public SimplePubSubProduceResultImpl(String topic,
 int partition,
 PubSubPosition pubSubPosition,
 int serializedSize)

Method Details

getPubSubPosition

public PubSubPosition getPubSubPosition()

Description copied from interface: PubSubProduceResult

The position of the record in the topic/partition.

Specified by:

getPubSubPosition in interface PubSubProduceResult

getSerializedSize

public int getSerializedSize()

Description copied from interface: PubSubProduceResult

Sum of the size of the serialized, uncompressed key and value in bytes.

Specified by:

getSerializedSize in interface PubSubProduceResult

getTopic

public String getTopic()

Description copied from interface: PubSubProduceResult

The topic the record was appended to

Specified by:

getTopic in interface PubSubProduceResult

getPartition

public int getPartition()

Description copied from interface: PubSubProduceResult

The partition the record was sent to

Specified by:

getPartition in interface PubSubProduceResult

toString

public String toString()

Overrides:

toString in class Object