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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description OptionalIntcoordinatorEpoch()OptionalLongcurrentTransactionStartOffset()booleanequals(Object o)inthashCode()intlastSequence()longlastTimestamp()intproducerEpoch()longproducerId()StringtoString()
-
-
-
Constructor Detail
-
ProducerState
public ProducerState(long producerId, int producerEpoch, int lastSequence, long lastTimestamp, OptionalInt coordinatorEpoch, OptionalLong currentTransactionStartOffset)
-
-
Method Detail
-
producerId
public long producerId()
-
producerEpoch
public int producerEpoch()
-
lastSequence
public int lastSequence()
-
lastTimestamp
public long lastTimestamp()
-
currentTransactionStartOffset
public OptionalLong currentTransactionStartOffset()
-
coordinatorEpoch
public OptionalInt coordinatorEpoch()
-
-