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 (42f46ab -> 4f96c5b4)
Date Thu, 11 Jun 2020 18:29:38 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 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


Mime
View raw message