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
