Skip to content

Commit ac715e8

Browse files
committed
fix version numbers
1 parent fb5704c commit ac715e8

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -396,7 +396,7 @@ public void testCannotDowngradeBeforeMinimumKraftVersion() {
396396
build();
397397
manager.replay(new FeatureLevelRecord().setName(MetadataVersion.FEATURE_NAME).setFeatureLevel(MetadataVersion.MINIMUM_VERSION.featureLevel()));
398398
assertEquals(ControllerResult.of(List.of(), new ApiError(Errors.INVALID_UPDATE_VERSION,
399-
"Invalid update version 6 for feature metadata.version. Local controller 0 only supports versions 7-30")),
399+
"Invalid update version 6 for feature metadata.version. Local controller 0 only supports versions 7-29")),
400400
manager.updateFeatures(
401401
Map.of(MetadataVersion.FEATURE_NAME, MetadataVersionTestUtils.IBP_3_3_IV2_FEATURE_LEVEL),
402402
Map.of(MetadataVersion.FEATURE_NAME, FeatureUpdate.UpgradeType.UNSAFE_DOWNGRADE),

server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -127,15 +127,15 @@ public enum MetadataVersion {
127127
// *** SHARE GROUPS BECOME PRODUCTION-READY IN THE FUTURE. ITS DEFINITION ALLOWS A SHARE ***
128128
// *** GROUPS FEATURE TO BE DEFINED IN 4.1 BUT TURNED OFF BY DEFAULT, ABLE TO BE TURNED ON ***
129129
// *** DYNAMICALLY TO TRY OUT THE PREVIEW CAPABILITY. ***
130-
IBP_4_2_IV0(29, "4.2", "IV0", false),
130+
IBP_4_2_IV0(28, "4.2", "IV0", false),
131131

132132
// Enables "streams" groups by default for new clusters (KIP-1071).
133133
//
134134
// *** THIS IS A PLACEHOLDER UNSTABLE VERSION WHICH IS USED TO DEFINE THE POINT AT WHICH ***
135135
// *** STREAMS GROUPS BECOME PRODUCTION-READY IN THE FUTURE. ITS DEFINITION ALLOWS A STREAMS ***
136136
// *** GROUPS FEATURE TO BE DEFINED IN 4.1 BUT TURNED OFF BY DEFAULT, ABLE TO BE TURNED ON ***
137137
// *** DYNAMICALLY TO TRY OUT THE EARLY ACCESS CAPABILITY. ***
138-
IBP_4_2_IV1(30, "4.2", "IV1", false);
138+
IBP_4_2_IV1(29, "4.2", "IV1", false);
139139

140140
// NOTES when adding a new version:
141141
// Update the default version in @ClusterTest annotation to point to the latest version

tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ public void testDowngradeMetadataVersionWithKRaft(ClusterInstance cluster) {
122122
);
123123
// Change expected message to reflect possible MetadataVersion range 1-N (N increases when adding a new version)
124124
assertEquals("Could not disable metadata.version. The update failed for all features since the following " +
125-
"feature had an error: Invalid update version 0 for feature metadata.version. Local controller 3000 only supports versions 7-30", commandOutput);
125+
"feature had an error: Invalid update version 0 for feature metadata.version. Local controller 3000 only supports versions 7-29", commandOutput);
126126

127127
commandOutput = ToolsTestUtils.captureStandardOut(() ->
128128
assertEquals(1, FeatureCommand.mainNoExit("--bootstrap-server", cluster.bootstrapServers(),

0 commit comments

Comments
 (0)