You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by rs...@apache.org on 2020/07/22 18:13:30 UTC

[kafka] branch trunk updated (a5ffd1c -> d916897)

This is an automated email from the ASF dual-hosted git repository.

rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from a5ffd1c  KAFKA-10163; Throttle Create Topic, Create Partition and Delete Topic Operations (KIP-599, Part I, Broker Changes) (#8933)
     add d916897  KAFKA-10164; Throttle Create Topic, Create Partition and Delete Topic Operations (KIP-599, Part II, Admin Changes) (#8968)

No new revisions were added by this update.

Summary of changes:
 .../clients/admin/CreatePartitionsOptions.java     |  18 +-
 .../kafka/clients/admin/CreateTopicsOptions.java   |  16 +
 .../kafka/clients/admin/DeleteTopicsOptions.java   |  16 +
 .../kafka/clients/admin/KafkaAdminClient.java      | 292 +++++++-----
 .../org/apache/kafka/common/requests/ApiError.java |   5 +
 .../common/message/CreatePartitionsRequest.json    |   2 +-
 .../kafka/clients/admin/KafkaAdminClientTest.java  | 497 +++++++++++++++++++--
 .../kafka/common/requests/RequestResponseTest.java |   5 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |   2 +-
 .../kafka/api/AuthorizerIntegrationTest.scala      |   2 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   2 +-
 11 files changed, 694 insertions(+), 163 deletions(-)