THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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;
}
...
} |
...