root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Cleanup MetadataVersion (#18623) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
TengYao Chi 2025-01-19 23:48:37 +08:00 committed by GitHub
parent 697cf641bc
commit 3490cf7bfc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -157,7 +157,7 @@ public enum MetadataVersion {
// LATEST_STABLE_METADATA_VERSION version in tests/kafkatest/version.py // 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 * This is essentially a cached copy of MetadataVersion.values. Unlike that function, it doesn't
* allocate a new array each time. * allocate a new array each time.
@ -169,10 +169,6 @@ public enum MetadataVersion {
private final String ibpVersion; private final String ibpVersion;
private final boolean didMetadataChange; 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) { MetadataVersion(int featureLevel, String release, String subVersion, boolean didMetadataChange) {
this.featureLevel = (short) featureLevel; this.featureLevel = (short) featureLevel;
this.release = release; this.release = release;
@ -200,10 +196,6 @@ public enum MetadataVersion {
return this.isAtLeast(IBP_3_3_IV1); return this.isAtLeast(IBP_3_3_IV1);
} }
public boolean isApiForwardingEnabled() {
return this.isAtLeast(IBP_3_4_IV0);
}
public boolean isScramSupported() { public boolean isScramSupported() {
return this.isAtLeast(IBP_3_5_IV2); return this.isAtLeast(IBP_3_5_IV2);
} }