diff --git a/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java b/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java index b97a137d3ce..310a9242b23 100644 --- a/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java +++ b/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java @@ -157,7 +157,7 @@ public enum MetadataVersion { // LATEST_STABLE_METADATA_VERSION version in tests/kafkatest/version.py /** - * An array containing all of the MetadataVersion entries. + * An array containing all the MetadataVersion entries. * * This is essentially a cached copy of MetadataVersion.values. Unlike that function, it doesn't * allocate a new array each time. @@ -169,10 +169,6 @@ public enum MetadataVersion { private final String ibpVersion; private final boolean didMetadataChange; - MetadataVersion(int featureLevel, String release, String subVersion) { - this(featureLevel, release, subVersion, true); - } - MetadataVersion(int featureLevel, String release, String subVersion, boolean didMetadataChange) { this.featureLevel = (short) featureLevel; this.release = release; @@ -200,10 +196,6 @@ public enum MetadataVersion { return this.isAtLeast(IBP_3_3_IV1); } - public boolean isApiForwardingEnabled() { - return this.isAtLeast(IBP_3_4_IV0); - } - public boolean isScramSupported() { return this.isAtLeast(IBP_3_5_IV2); }