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()