public class ProducerState extends Object
Constructor and Description |
---|
ProducerState(long producerId,
int producerEpoch,
int lastSequence,
long lastTimestamp,
OptionalInt coordinatorEpoch,
OptionalLong currentTransactionStartOffset) |
Modifier and Type | Method and Description |
---|---|
OptionalInt |
coordinatorEpoch() |
OptionalLong |
currentTransactionStartOffset() |
boolean |
equals(Object o) |
int |
hashCode() |
int |
lastSequence() |
long |
lastTimestamp() |
int |
producerEpoch() |
long |
producerId() |
String |
toString() |
public ProducerState(long producerId, int producerEpoch, int lastSequence, long lastTimestamp, OptionalInt coordinatorEpoch, OptionalLong currentTransactionStartOffset)
public long producerId()
public int producerEpoch()
public int lastSequence()
public long lastTimestamp()
public OptionalLong currentTransactionStartOffset()
public OptionalInt coordinatorEpoch()