@InterfaceStability.Evolving public class TransactionDescription extends Object
| Constructor and Description |
|---|
TransactionDescription(int coordinatorId, TransactionState state, long producerId, int producerEpoch, long transactionTimeoutMs, OptionalLong transactionStartTimeMs, Set<TopicPartition> topicPartitions) |
| Modifier and Type | Method and Description |
|---|---|
int | coordinatorId() |
boolean | equals(Object o) |
int | hashCode() |
int | producerEpoch() |
long | producerId() |
TransactionState | state() |
Set<TopicPartition> | topicPartitions() |
String | toString() |
OptionalLong | transactionStartTimeMs() |
long | transactionTimeoutMs() |
public TransactionDescription(int coordinatorId,
TransactionState state,
long producerId,
int producerEpoch,
long transactionTimeoutMs,
OptionalLong transactionStartTimeMs,
Set<TopicPartition> topicPartitions)public int coordinatorId()
public TransactionState state()
public long producerId()
public int producerEpoch()
public long transactionTimeoutMs()
public OptionalLong transactionStartTimeMs()
public Set<TopicPartition> topicPartitions()