You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2021/03/02 21:02:54 UTC
[kafka] branch trunk updated (a848e0c -> 3708a7c)
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%)