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/25 03:17:30 UTC
[kafka] branch trunk updated (9bf5c57 -> 3ab9ab6)

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 9bf5c57  KAFKA-12435: Fix javadoc errors (#10392)
     add 3ab9ab6  KAFKA-12434; Admin support for `DescribeProducers` API (#10275)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/admin/Admin.java |  22 +
 ...ToDelete.java => DescribeProducersOptions.java} |  47 +-
 .../clients/admin/DescribeProducersResult.java     |  76 +++
 .../kafka/clients/admin/KafkaAdminClient.java      | 116 +++-
 .../apache/kafka/clients/admin/ProducerState.java  | 101 +++
 .../clients/admin/internals/AdminApiDriver.java    | 465 +++++++++++++
 .../clients/admin/internals/AdminApiHandler.java   | 139 ++++
 .../admin/internals/AdminApiLookupStrategy.java    |  88 +++
 .../ApiRequestScope.java}                          |  30 +-
 .../admin/internals/DescribeProducersHandler.java  | 205 ++++++
 .../admin/internals/PartitionLeaderStrategy.java   | 184 +++++
 .../kafka/common/errors/InvalidTopicException.java |   5 +
 .../apache/kafka/common/utils/CollectionUtils.java |  28 +-
 .../java/org/apache/kafka/common/utils/Utils.java  |   7 +
 .../java/org/apache/kafka/clients/MockClient.java  |   6 +-
 .../kafka/clients/admin/KafkaAdminClientTest.java  | 187 +++++
 .../kafka/clients/admin/MockAdminClient.java       |  11 +-
 .../admin/internals/AdminApiDriverTest.java        | 759 +++++++++++++++++++++
 .../internals/DescribeProducersHandlerTest.java    | 335 +++++++++
 .../internals/PartitionLeaderStrategyTest.java     | 302 ++++++++
 .../clients/producer/internals/SenderTest.java     |   5 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  35 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  33 +-
 23 files changed, 3102 insertions(+), 84 deletions(-)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{RecordsToDelete.java => DescribeProducersOptions.java} (60%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/DescribeProducersResult.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/ProducerState.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiHandler.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiLookupStrategy.java
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DescribeAclsOptions.java => internals/ApiRequestScope.java} (52%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeProducersHandler.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategy.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminApiDriverTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeProducersHandlerTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategyTest.java