Package com.networknt.kafka.producer

Class ProduceResult

java.lang.Object

com.networknt.kafka.producer.ProduceResult

public class ProduceResult
extends Object

Constructor Summary

Constructors

Constructor	Description
ProduceResult()
ProduceResult(int partitionId, long offset, Instant timestamp, int serializeKeySize, int serializeValueSize)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static ProduceResult	fromRecordMetadata(org.apache.kafka.clients.producer.RecordMetadata metadata)
long	getOffset()
int	getPartitionId()
int	getSerializeKeySize()
int	getSerializeValueSize()
Instant	getTimestamp()
int	hashCode()
void	setOffset(long offset)
void	setPartitionId(int partitionId)
void	setSerializeKeySize(int serializeKeySize)
void	setSerializeValueSize(int serializeValueSize)
void	setTimestamp(Instant timestamp)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProduceResult

public ProduceResult()

ProduceResult

public ProduceResult(int partitionId,
                     long offset,
                     Instant timestamp,
                     int serializeKeySize,
                     int serializeValueSize)

Method Detail

getPartitionId

public int getPartitionId()

setPartitionId

public void setPartitionId(int partitionId)

getOffset

public long getOffset()

setOffset

public void setOffset(long offset)

getTimestamp

public Instant getTimestamp()

setTimestamp

public void setTimestamp(Instant timestamp)

getSerializeKeySize

public int getSerializeKeySize()

setSerializeKeySize

public void setSerializeKeySize(int serializeKeySize)

getSerializeValueSize

public int getSerializeValueSize()

setSerializeValueSize

public void setSerializeValueSize(int serializeValueSize)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

fromRecordMetadata

public static ProduceResult fromRecordMetadata(org.apache.kafka.clients.producer.RecordMetadata metadata)