Package org.apache.kafka.clients.admin
Class TransactionDescription
java.lang.Object
org.apache.kafka.clients.admin.TransactionDescription
@Evolving public class TransactionDescription extends Object
-
Constructor Summary
Constructors Constructor Description TransactionDescription(int coordinatorId, TransactionState state, long producerId, int producerEpoch, long transactionTimeoutMs, OptionalLong transactionStartTimeMs, Set<TopicPartition> topicPartitions)
-
Method Summary
Modifier and Type Method Description int
coordinatorId()
boolean
equals(Object o)
int
hashCode()
int
producerEpoch()
long
producerId()
TransactionState
state()
Set<TopicPartition>
topicPartitions()
String
toString()
OptionalLong
transactionStartTimeMs()
long
transactionTimeoutMs()
-
Constructor Details
-
TransactionDescription
public TransactionDescription(int coordinatorId, TransactionState state, long producerId, int producerEpoch, long transactionTimeoutMs, OptionalLong transactionStartTimeMs, Set<TopicPartition> topicPartitions)
-
-
Method Details
-
coordinatorId
public int coordinatorId() -
state
-
producerId
public long producerId() -
producerEpoch
public int producerEpoch() -
transactionTimeoutMs
public long transactionTimeoutMs() -
transactionStartTimeMs
-
topicPartitions
-
equals
-
hashCode
public int hashCode() -
toString
-