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

Posted to commits@kafka.apache.org by mi...@apache.org on 2020/03/13 17:49:34 UTC

[kafka] branch trunk updated (e3ccf20 -> f869e33)

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

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


    from e3ccf20  KAFKA-9685: Solve Set concatenation perf issue in AclAuthorizer
     add f869e33  KAFKA-8768: DeleteRecords request/response automated protocol (#7957)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/admin/KafkaAdminClient.java      |  58 ++++++---
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   6 +-
 .../kafka/common/requests/AbstractResponse.java    |   2 +-
 .../common/requests/DeleteRecordsRequest.java      | 142 +++++----------------
 .../common/requests/DeleteRecordsResponse.java     | 136 +++-----------------
 .../common/message/DeleteRecordsRequest.json       |   6 +-
 .../common/message/DeleteRecordsResponse.json      |  10 +-
 .../kafka/clients/admin/KafkaAdminClientTest.java  |  42 ++++--
 .../scala/kafka/server/DelayedDeleteRecords.scala  |  15 ++-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  48 +++++--
 .../main/scala/kafka/server/ReplicaManager.scala   |   8 +-
 .../kafka/api/AuthorizerIntegrationTest.scala      |  25 ++--
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   9 +-
 13 files changed, 206 insertions(+), 301 deletions(-)