Class SimplePubSubProduceResultImpl
- java.lang.Object
-
- com.linkedin.venice.pubsub.adapter.SimplePubSubProduceResultImpl
-
- All Implemented Interfaces:
PubSubProduceResult
- Direct Known Subclasses:
ApacheKafkaProduceResult
public class SimplePubSubProduceResultImpl extends java.lang.Object implements PubSubProduceResult
A simple implementation of PubSubProduceResult interface for testing purposes.
-
-
Constructor Summary
Constructors Constructor Description SimplePubSubProduceResultImpl(java.lang.String topic, int partition, long offset, int serializedSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getOffset()
The offset of the record in the topic/partition.int
getPartition()
The partition the record was sent toint
getSerializedSize()
Sum of the size of the serialized, uncompressed key and value in bytes.java.lang.String
getTopic()
The topic the record was appended tojava.lang.String
toString()
-
-
-
Method Detail
-
getOffset
public long getOffset()
Description copied from interface:PubSubProduceResult
The offset of the record in the topic/partition.- Specified by:
getOffset
in interfacePubSubProduceResult
-
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 interfacePubSubProduceResult
-
getTopic
public java.lang.String getTopic()
Description copied from interface:PubSubProduceResult
The topic the record was appended to- Specified by:
getTopic
in interfacePubSubProduceResult
-
getPartition
public int getPartition()
Description copied from interface:PubSubProduceResult
The partition the record was sent to- Specified by:
getPartition
in interfacePubSubProduceResult
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-