kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [kafka] branch trunk updated (4e65030 -> fb4f297)
Date Wed, 07 Oct 2020 17:25:02 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 4e65030  KAFKA-10402: Upgrade system tests to python3 (#9196)
     add fb4f297  KAFKA-10028: Implement write path for feature versioning system (KIP-584)
(#9001)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/admin/Admin.java |  68 +++
 ...asOptions.java => DescribeFeaturesOptions.java} |  28 +-
 ...irsOptions.java => DescribeFeaturesResult.java} |  20 +-
 .../kafka/clients/admin/FeatureMetadata.java       | 111 ++++
 .../apache/kafka/clients/admin/FeatureUpdate.java  |  78 +++
 .../kafka/clients/admin/FinalizedVersionRange.java |  84 +++
 .../kafka/clients/admin/KafkaAdminClient.java      | 152 ++++++
 .../kafka/clients/admin/SupportedVersionRange.java |  82 +++
 ...ordsOptions.java => UpdateFeaturesOptions.java} |  11 +-
 ...TopicsResult.java => UpdateFeaturesResult.java} |  25 +-
 ...tion.java => FeatureUpdateFailedException.java} |   8 +-
 .../kafka/common/feature/BaseVersionRange.java     |  21 +-
 .../common/feature/FinalizedVersionRange.java      |   4 +-
 .../common/feature/SupportedVersionRange.java      |  10 +-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   6 +-
 .../org/apache/kafka/common/protocol/Errors.java   |   4 +-
 .../kafka/common/requests/AbstractRequest.java     |   2 +
 .../kafka/common/requests/AbstractResponse.java    |   2 +
 .../kafka/common/requests/ApiVersionsResponse.java |  58 +-
 .../common/requests/UpdateFeaturesRequest.java     |  95 ++++
 .../common/requests/UpdateFeaturesResponse.java    | 109 ++++
 .../common/message/ApiVersionsResponse.json        |   4 +-
 .../common/message/UpdateFeaturesRequest.json      |  35 ++
 ...lsResponse.json => UpdateFeaturesResponse.json} |  20 +-
 .../kafka/clients/admin/KafkaAdminClientTest.java  | 236 +++++++++
 .../kafka/clients/admin/MockAdminClient.java       |  10 +
 .../scala/kafka/controller/ControllerState.scala   |   7 +-
 .../scala/kafka/controller/KafkaController.scala   | 434 ++++++++++++++-
 .../main/scala/kafka/server/BrokerFeatures.scala   | 116 ++++
 .../scala/kafka/server/FinalizedFeatureCache.scala |  91 +++-
 .../server/FinalizedFeatureChangeListener.scala    |  16 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  56 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala |   2 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |  18 +-
 .../scala/kafka/server/SupportedFeatures.scala     |  93 ----
 core/src/main/scala/kafka/zk/KafkaZkClient.scala   |   3 +-
 core/src/main/scala/kafka/zk/ZkData.scala          |  41 +-
 .../controller/ControllerIntegrationTest.scala     | 104 +++-
 .../unit/kafka/server/BrokerFeaturesTest.scala     | 106 ++++
 .../kafka/server/FinalizedFeatureCacheTest.scala   |  78 +--
 .../FinalizedFeatureChangeListenerTest.scala       | 144 +++--
 .../scala/unit/kafka/server/KafkaApisTest.scala    |   7 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   3 +
 .../unit/kafka/server/SupportedFeaturesTest.scala  |  56 --
 .../unit/kafka/server/UpdateFeaturesTest.scala     | 581 +++++++++++++++++++++
 .../jmh/metadata/MetadataRequestBenchmark.java     |   7 +-
 46 files changed, 2831 insertions(+), 415 deletions(-)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{AlterClientQuotasOptions.java
=> DescribeFeaturesOptions.java} (53%)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DescribeLogDirsOptions.java =>
DescribeFeaturesResult.java} (69%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/FeatureMetadata.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/SupportedVersionRange.java
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DeleteRecordsOptions.java =>
UpdateFeaturesOptions.java} (81%)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DeleteTopicsResult.java =>
UpdateFeaturesResult.java} (70%)
 copy clients/src/main/java/org/apache/kafka/common/errors/{BrokerNotAvailableException.java
=> FeatureUpdateFailedException.java} (81%)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesRequest.java
 create mode 100644 clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java
 create mode 100644 clients/src/main/resources/common/message/UpdateFeaturesRequest.json
 copy clients/src/main/resources/common/message/{AlterUserScramCredentialsResponse.json =>
UpdateFeaturesResponse.json} (60%)
 create mode 100644 core/src/main/scala/kafka/server/BrokerFeatures.scala
 delete mode 100644 core/src/main/scala/kafka/server/SupportedFeatures.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/BrokerFeaturesTest.scala
 delete mode 100644 core/src/test/scala/unit/kafka/server/SupportedFeaturesTest.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/UpdateFeaturesTest.scala


Mime
View raw message