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%)