You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2020/06/11 18:29:38 UTC
[kafka] branch trunk updated (42f46ab -> 4f96c5b4)
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 42f46ab KAFKA-10085: correctly compute lag for optimized source changelogs (#8787)
add 4f96c5b4 KAFKA-10027: Implement read path for feature versioning system (KIP-584) (#8680)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 1 +
.../kafka/common/feature/BaseVersionRange.java | 124 ++++++++++
.../org/apache/kafka/common/feature/Features.java | 184 +++++++++++++++
.../common/feature/FinalizedVersionRange.java | 53 +++++
.../common/feature/SupportedVersionRange.java | 40 ++++
.../kafka/common/requests/ApiVersionsResponse.java | 85 ++++++-
.../common/message/ApiVersionsResponse.json | 29 ++-
.../clients/consumer/internals/FetcherTest.java | 6 +-
.../clients/producer/internals/SenderTest.java | 6 +-
.../apache/kafka/common/feature/FeaturesTest.java | 173 ++++++++++++++
.../common/feature/FinalizedVersionRangeTest.java | 80 +++++++
.../common/feature/SupportedVersionRangeTest.java | 142 ++++++++++++
.../common/requests/ApiVersionsResponseTest.java | 56 ++++-
core/src/main/scala/kafka/api/ApiVersion.scala | 11 +-
core/src/main/scala/kafka/cluster/Broker.scala | 19 +-
.../scala/kafka/server/FinalizedFeatureCache.scala | 99 ++++++++
.../server/FinalizedFeatureChangeListener.scala | 251 +++++++++++++++++++++
core/src/main/scala/kafka/server/KafkaApis.scala | 20 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 5 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 19 +-
.../scala/kafka/server/SupportedFeatures.scala | 93 ++++++++
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 23 ++
core/src/main/scala/kafka/zk/ZkData.scala | 229 ++++++++++++++++++-
.../src/test/scala/kafka/zk/FeatureZNodeTest.scala | 123 ++++++++++
.../unit/kafka/cluster/BrokerEndPointTest.scala | 51 +++++
.../kafka/server/FinalizedFeatureCacheTest.scala | 116 ++++++++++
.../FinalizedFeatureChangeListenerTest.scala | 225 ++++++++++++++++++
.../unit/kafka/server/SupportedFeaturesTest.scala | 56 +++++
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 39 +++-
29 files changed, 2315 insertions(+), 43 deletions(-)
create mode 100644 clients/src/main/java/org/apache/kafka/common/feature/BaseVersionRange.java
create mode 100644 clients/src/main/java/org/apache/kafka/common/feature/Features.java
create mode 100644 clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java
create mode 100644 clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
create mode 100644 clients/src/test/java/org/apache/kafka/common/feature/FeaturesTest.java
create mode 100644 clients/src/test/java/org/apache/kafka/common/feature/FinalizedVersionRangeTest.java
create mode 100644 clients/src/test/java/org/apache/kafka/common/feature/SupportedVersionRangeTest.java
create mode 100644 core/src/main/scala/kafka/server/FinalizedFeatureCache.scala
create mode 100644 core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala
create mode 100644 core/src/main/scala/kafka/server/SupportedFeatures.scala
create mode 100644 core/src/test/scala/kafka/zk/FeatureZNodeTest.scala
create mode 100644 core/src/test/scala/unit/kafka/server/FinalizedFeatureCacheTest.scala
create mode 100644 core/src/test/scala/unit/kafka/server/FinalizedFeatureChangeListenerTest.scala
create mode 100644 core/src/test/scala/unit/kafka/server/SupportedFeaturesTest.scala