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/02/24 20:51:21 UTC
[kafka] branch trunk updated (059c9b3 -> 3f09fb9)
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 059c9b3 MINOR: Fix the generation extraction util (#10204)
add 3f09fb9 KAFKA-12267; Implement `DescribeTransactions` API (#10183)
No new revisions were added by this update.
Summary of changes:
....java => TransactionalIdNotFoundException.java} | 4 +-
.../org/apache/kafka/common/protocol/ApiKeys.java | 3 +-
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
.../requests/DescribeTransactionsRequest.java | 85 +++++++++++++++
...onse.java => DescribeTransactionsResponse.java} | 38 +++----
.../common/message/DescribeProducersResponse.json | 2 +-
...quest.json => DescribeTransactionsRequest.json} | 8 +-
.../message/DescribeTransactionsResponse.json | 42 +++++++
.../kafka/common/requests/RequestResponseTest.java | 52 +++++++++
.../transaction/TransactionCoordinator.scala | 54 ++++++++-
.../transaction/TransactionMetadata.scala | 49 +++++++--
.../scala/kafka/network/RequestConvertToJson.scala | 2 +
core/src/main/scala/kafka/server/KafkaApis.scala | 31 +++++-
.../kafka/api/AuthorizerIntegrationTest.scala | 49 ++++++++-
.../transaction/TransactionCoordinatorTest.scala | 51 +++++++++
.../scala/unit/kafka/server/KafkaApisTest.scala | 121 +++++++++++++++++++++
.../scala/unit/kafka/server/RequestQuotaTest.scala | 4 +
.../test/scala/unit/kafka/utils/TestUtils.scala | 27 ++++-
20 files changed, 576 insertions(+), 54 deletions(-)
copy clients/src/main/java/org/apache/kafka/common/errors/{DuplicateSequenceException.java => TransactionalIdNotFoundException.java} (86%)
create mode 100644 clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsRequest.java
copy clients/src/main/java/org/apache/kafka/common/requests/{BrokerRegistrationResponse.java => DescribeTransactionsResponse.java} (62%)
copy clients/src/main/resources/common/message/{DescribeClusterRequest.json => DescribeTransactionsRequest.json} (76%)
create mode 100644 clients/src/main/resources/common/message/DescribeTransactionsResponse.json