Package org.apache.kafka.clients.admin
Class ProducerState
java.lang.Object
org.apache.kafka.clients.admin.ProducerState
public class ProducerState extends Object
-
Constructor Summary
Constructors Constructor Description ProducerState(long producerId, int producerEpoch, int lastSequence, long lastTimestamp, OptionalInt coordinatorEpoch, OptionalLong currentTransactionStartOffset)
-
Method Summary
Modifier and Type Method Description OptionalInt
coordinatorEpoch()
OptionalLong
currentTransactionStartOffset()
boolean
equals(Object o)
int
hashCode()
int
lastSequence()
long
lastTimestamp()
int
producerEpoch()
long
producerId()
String
toString()
-
Constructor Details
-
ProducerState
public ProducerState(long producerId, int producerEpoch, int lastSequence, long lastTimestamp, OptionalInt coordinatorEpoch, OptionalLong currentTransactionStartOffset)
-
-
Method Details
-
producerId
public long producerId() -
producerEpoch
public int producerEpoch() -
lastSequence
public int lastSequence() -
lastTimestamp
public long lastTimestamp() -
currentTransactionStartOffset
-
coordinatorEpoch
-
equals
-
hashCode
public int hashCode() -
toString
-