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
