This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from a848e0c KAFKA-10357: Extract setup of changelog from Streams
partition assignor (#10163)
add 3708a7c KAFKA-12369; Implement `ListTransactions` API (#10206)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/protocol/ApiKeys.java | 3 +-
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
...enRequest.java => ListTransactionsRequest.java} | 75 ++++++++++++----------
...Response.java => ListTransactionsResponse.java} | 36 +++++------
.../message/DescribeTransactionsResponse.json | 2 +-
...nsRequest.json => ListTransactionsRequest.json} | 12 ++--
...Response.json => ListTransactionsResponse.json} | 25 +++-----
.../kafka/common/requests/RequestResponseTest.java | 34 ++++++++++
.../transaction/TransactionCoordinator.scala | 14 +++-
.../coordinator/transaction/TransactionLog.scala | 4 +-
.../transaction/TransactionMetadata.scala | 64 +++++++++++-------
.../transaction/TransactionStateManager.scala | 53 +++++++++++++++
.../scala/kafka/network/RequestConvertToJson.scala | 2 +
core/src/main/scala/kafka/server/KafkaApis.scala | 21 ++++++
.../kafka/api/AuthorizerIntegrationTest.scala | 35 +++++++++-
.../transaction/TransactionMetadataTest.scala | 39 ++++++++++-
.../transaction/TransactionStateManagerTest.scala | 70 +++++++++++++++++++-
.../scala/unit/kafka/server/KafkaApisTest.scala | 67 +++++++++++++++++++
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +
20 files changed, 457 insertions(+), 106 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/requests/{RenewDelegationTokenRequest.java
=> ListTransactionsRequest.java} (51%)
copy
clients/src/main/java/org/apache/kafka/common/requests/{BrokerHeartbeatResponse.java
=> ListTransactionsResponse.java} (66%)
copy
clients/src/main/resources/common/message/{DescribeTransactionsRequest.json =>
ListTransactionsRequest.json} (61%)
copy
clients/src/main/resources/common/message/{DescribeTransactionsResponse.json =>
ListTransactionsResponse.json} (62%)
