kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (21532a7 -> 2d7a4ed)
Date Wed, 02 Jun 2021 01:01:23 GMT
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 21532a7  KAFKA-12596: remove --zookeeper option from topic command (#10457)
     add 2d7a4ed  KAFKA-12709; Add Admin API for `ListTransactions` (#10616)

No new revisions were added by this update.

Summary of changes:
 .../clients/admin/AbortTransactionOptions.java     |   8 +
 .../java/org/apache/kafka/clients/admin/Admin.java |  22 ++
 .../clients/admin/DescribeProducersResult.java     |   7 +
 .../clients/admin/DescribeTransactionsOptions.java |   7 +
 .../kafka/clients/admin/KafkaAdminClient.java      |  49 ++--
 .../clients/admin/ListTransactionsOptions.java     |  91 ++++++++
 .../clients/admin/ListTransactionsResult.java      | 125 +++++++++++
 ...ransactionSpec.java => TransactionListing.java} |  49 ++--
 .../admin/internals/AbortTransactionHandler.java   |  14 +-
 .../clients/admin/internals/AdminApiDriver.java    | 160 ++++++-------
 .../clients/admin/internals/AdminApiFuture.java    | 125 +++++++++++
 .../clients/admin/internals/AdminApiHandler.java   |  70 ++----
 .../admin/internals/AdminApiLookupStrategy.java    |  24 ++
 .../admin/internals/AdminMetadataManager.java      |   2 +-
 .../admin/internals/AllBrokersStrategy.java        | 212 ++++++++++++++++++
 .../clients/admin/internals/ApiRequestScope.java   |   6 +-
 .../admin/internals/DescribeProducersHandler.java  |  34 +--
 .../internals/DescribeTransactionsHandler.java     |  17 +-
 .../admin/internals/ListTransactionsHandler.java   | 130 +++++++++++
 .../admin/internals/StaticBrokerStrategy.java      |  65 ++++++
 .../kafka/clients/admin/KafkaAdminClientTest.java  |  55 +++++
 .../clients/admin/ListTransactionsResultTest.java  | 119 ++++++++++
 .../kafka/clients/admin/MockAdminClient.java       |   5 +
 .../admin/internals/AdminApiDriverTest.java        | 207 +++++++++--------
 .../AllBrokersStrategyIntegrationTest.java         | 247 +++++++++++++++++++++
 .../admin/internals/AllBrokersStrategyTest.java    | 124 +++++++++++
 .../internals/DescribeProducersHandlerTest.java    |  31 +--
 .../internals/DescribeTransactionsHandlerTest.java |   7 +-
 .../internals/ListTransactionsHandlerTest.java     | 185 +++++++++++++++
 29 files changed, 1874 insertions(+), 323 deletions(-)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsOptions.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsResult.java
 copy clients/src/main/java/org/apache/kafka/clients/admin/{AbortTransactionSpec.java =>
TransactionListing.java} (55%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiFuture.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategy.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandler.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/StaticBrokerStrategy.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/ListTransactionsResultTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategyIntegrationTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategyTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandlerTest.java

Mime
View raw message