This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new cd4d6ce9d57 MINOR: fix failed cases in FeatureCommandTest (#17287)
cd4d6ce9d57 is described below
commit cd4d6ce9d576b170c10f81f3081529885abb933c
Author: PoAn Yang <[email protected]>
AuthorDate: Thu Sep 26 23:24:09 2024 +0800
MINOR: fix failed cases in FeatureCommandTest (#17287)
Reviewers: David Arthur <[email protected]>
---
tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java
b/tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java
index 2cb7078d000..7e4e36cbf95 100644
--- a/tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java
+++ b/tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java
@@ -71,7 +71,7 @@ public class FeatureCommandTest {
assertEquals("Feature: kraft.version\tSupportedMinVersion: 0\t" +
"SupportedMaxVersion: 1\tFinalizedVersionLevel: 0\t",
outputWithoutEpoch(features.get(1)));
assertEquals("Feature: metadata.version\tSupportedMinVersion:
3.0-IV1\t" +
- "SupportedMaxVersion: 4.0-IV2\tFinalizedVersionLevel:
3.3-IV1\t", outputWithoutEpoch(features.get(2)));
+ "SupportedMaxVersion: 4.0-IV3\tFinalizedVersionLevel:
3.3-IV1\t", outputWithoutEpoch(features.get(2)));
assertEquals("Feature: transaction.version\tSupportedMinVersion: 0\t" +
"SupportedMaxVersion: 2\tFinalizedVersionLevel: 0\t",
outputWithoutEpoch(features.get(3)));
}
@@ -91,7 +91,7 @@ public class FeatureCommandTest {
assertEquals("Feature: kraft.version\tSupportedMinVersion: 0\t" +
"SupportedMaxVersion: 1\tFinalizedVersionLevel: 0\t",
outputWithoutEpoch(features.get(1)));
assertEquals("Feature: metadata.version\tSupportedMinVersion:
3.0-IV1\t" +
- "SupportedMaxVersion: 4.0-IV2\tFinalizedVersionLevel:
3.7-IV0\t", outputWithoutEpoch(features.get(2)));
+ "SupportedMaxVersion: 4.0-IV3\tFinalizedVersionLevel:
3.7-IV0\t", outputWithoutEpoch(features.get(2)));
assertEquals("Feature: transaction.version\tSupportedMinVersion: 0\t" +
"SupportedMaxVersion: 2\tFinalizedVersionLevel: 0\t",
outputWithoutEpoch(features.get(3)));
}
@@ -152,7 +152,7 @@ public class FeatureCommandTest {
);
// Change expected message to reflect possible MetadataVersion range
1-N (N increases when adding a new version)
assertEquals("Could not disable metadata.version. Invalid update
version 0 for feature " +
- "metadata.version. Local controller 3000 only supports
versions 1-24", commandOutput);
+ "metadata.version. Local controller 3000 only supports
versions 1-25", commandOutput);
commandOutput = ToolsTestUtils.captureStandardOut(() ->
assertEquals(1,
FeatureCommand.mainNoExit("--bootstrap-server", cluster.bootstrapServers(),
