THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
| Table of Contents |
|---|
Status
Current state: In DiscussionAccepted
Discussion thread: here (Vote thread: here)
JIRA: here
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Add transactionLastUpdateTimeMs to TransactionDescription class. This object is used to build APIResult at org.apache.kafka.clients.admin.internals.DescribeTransactionsHandler#handleResponse from DescribeTransactionsResponse .
We will also add an overloaded public constructor to this class to incorporate the value for transactionLastUpdateTimeMs field.
| Code Block |
|---|
package org.apache.kafka.clients.admin;
public class TransactionDescription {
...
private final OptionalLong transactionLastUpdateTimeMs;
...
public TransactionDescription(
int coordinatorId,
TransactionState state,
long producerId,
int producerEpoch,
long transactionTimeoutMs,
OptionalLong transactionStartTimeMs,
Set<TopicPartition> topicPartitions
) {
new TransactionDescription(coordinatorId, state, producerId, producerEpoch, transactionTimeoutMs, transactionStartTimeMs, OptionalLong.empty(), topicPartitions);
}
// new overloaded public constructor
public TransactionDescription(
int coordinatorId,
TransactionState state,
long producerId,
int producerEpoch,
long transactionTimeoutMs,
OptionalLong transactionStartTimeMs,
OptionalLong transactionLastUpdateTimeMs,
Set<TopicPartition> topicPartitions
) {
...
this.transactionLastUpdateTimeMs = transactionLastUpdateTimeMs;
...
}
...
public OptionalLong transactionLastUpdateTimeMs() {
return transactionLastUpdateTimeMs;
}
...
} |
...