You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2024/05/31 19:49:02 UTC

(kafka) branch trunk updated (f8ad9ee8920 -> ba61ff0cd94)

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

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


    from f8ad9ee8920 MINOR: update all-latency-avg documentation (#16148)
     add ba61ff0cd94 KAFKA-16860; [1/2] Introduce group.version feature flag (#16120)

No new revisions were added by this update.

Summary of changes:
 core/src/main/scala/kafka/server/KafkaApis.scala   | 13 ++-
 core/src/test/java/kafka/test/ClusterConfig.java   | 21 ++++-
 core/src/test/java/kafka/test/ClusterInstance.java |  5 +-
 .../java/kafka/test/ClusterTestExtensionsTest.java | 16 ++--
 .../java/kafka/test/annotation/ClusterFeature.java | 16 ++--
 .../java/kafka/test/annotation/ClusterTest.java    |  3 +-
 .../kafka/test/junit/ClusterTestExtensions.java    |  7 ++
 .../test/junit/RaftClusterInvocationContext.java   | 20 ++++-
 .../kafka/api/IntegrationTestHarness.scala         |  2 +-
 .../kafka/server/QuorumTestHarness.scala           | 11 ++-
 .../kafka/zk/ZkMigrationIntegrationTest.scala      |  3 +-
 .../server/AbstractApiVersionsRequestTest.scala    |  7 +-
 .../unit/kafka/server/ApiVersionsRequestTest.scala |  4 +-
 .../unit/kafka/server/BrokerFeaturesTest.scala     |  3 +-
 .../server/ConsumerGroupDescribeRequestsTest.scala | 48 +++++++++--
 .../server/ConsumerGroupHeartbeatRequestTest.scala | 75 +++++++++++++-----
 .../server/ConsumerProtocolMigrationTest.scala     | 48 +++++++----
 .../kafka/server/DeleteGroupsRequestTest.scala     | 50 +++++++-----
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 92 +++++++++++++++++++---
 .../unit/kafka/server/ListGroupsRequestTest.scala  | 22 ++++--
 .../kafka/server/OffsetCommitRequestTest.scala     | 34 +++++---
 .../kafka/server/OffsetDeleteRequestTest.scala     | 22 ++++--
 .../unit/kafka/server/OffsetFetchRequestTest.scala | 79 +++++++++++--------
 .../unit/kafka/server/ReplicationQuotasTest.scala  |  2 +-
 .../scala/unit/kafka/tools/StorageToolTest.scala   | 14 +++-
 .../kafka/controller/QuorumControllerTest.java     |  8 +-
 .../kafka/controller/QuorumFeaturesTest.java       |  2 +-
 .../org/apache/kafka/server/common/Features.java   |  3 +-
 .../{TestFeatureVersion.java => GroupVersion.java} | 28 ++++---
 .../kafka/server/common/MetadataVersion.java       |  5 +-
 .../kafka/server/common/MetadataVersionTest.java   |  6 ++
 .../org/apache/kafka/tools/FeatureCommandTest.java | 21 ++++-
 .../consumer/group/ConsumerGroupCommandTest.java   |  5 +-
 .../group/ConsumerGroupCommandTestUtils.java       |  5 ++
 34 files changed, 505 insertions(+), 195 deletions(-)
 copy clients/src/test/java/org/apache/kafka/common/utils/annotation/ApiKeyVersionsSource.java => core/src/test/java/kafka/test/annotation/ClusterFeature.java (77%)
 copy server-common/src/main/java/org/apache/kafka/server/common/{TestFeatureVersion.java => GroupVersion.java} (63%)