public enum MetadataVersion extends Enum<MetadataVersion>
Modifier and Type | Field and Description |
---|---|
static String |
FEATURE_NAME |
static MetadataVersion |
MINIMUM_BOOTSTRAP_VERSION
The first version we currently support in the bootstrap metadata.
|
static MetadataVersion |
MINIMUM_KRAFT_VERSION
The first version we currently support in KRaft.
|
static MetadataVersion[] |
VERSIONS |
Modifier and Type | Method and Description |
---|---|
static boolean |
checkIfMetadataChanged(MetadataVersion sourceVersion,
MetadataVersion targetVersion) |
boolean |
didMetadataChange() |
short |
featureLevel() |
short |
fetchRequestVersion() |
static MetadataVersion |
fromFeatureLevel(short version) |
static MetadataVersion |
fromVersionString(String versionString)
Return an `MetadataVersion` instance for `versionString`, which can be in a variety of formats (e.g.
|
org.apache.kafka.common.record.RecordVersion |
highestSupportedRecordVersion() |
boolean |
isAllocateProducerIdsSupported() |
boolean |
isAlterPartitionSupported() |
boolean |
isAtLeast(MetadataVersion otherVersion) |
boolean |
isBrokerRegistrationChangeRecordSupported() |
boolean |
isFeatureVersioningSupported() |
boolean |
isInControlledShutdownStateSupported() |
boolean |
isKRaftSupported() |
boolean |
isLeaderRecoverySupported() |
boolean |
isLessThan(MetadataVersion otherVersion) |
boolean |
isNoOpRecordSupported() |
boolean |
isOffsetForLeaderEpochSupported() |
boolean |
isSaslInterBrokerHandshakeRequestEnabled() |
boolean |
isTopicIdsSupported() |
boolean |
isTruncationOnFetchSupported() |
static MetadataVersion |
latest() |
short |
listOffsetRequestVersion() |
static MetadataVersion |
minSupportedFor(org.apache.kafka.common.record.RecordVersion recordVersion)
Return the minimum `MetadataVersion` that supports `RecordVersion`.
|
short |
offsetForLeaderEpochRequestVersion() |
short |
registerBrokerRecordVersion() |
String |
shortVersion() |
String |
toString() |
static MetadataVersion |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static MetadataVersion[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
String |
version() |
public static final MetadataVersion IBP_0_8_0
public static final MetadataVersion IBP_0_8_1
public static final MetadataVersion IBP_0_8_2
public static final MetadataVersion IBP_0_9_0
public static final MetadataVersion IBP_0_10_0_IV0
public static final MetadataVersion IBP_0_10_0_IV1
public static final MetadataVersion IBP_0_10_1_IV0
public static final MetadataVersion IBP_0_10_1_IV1
public static final MetadataVersion IBP_0_10_1_IV2
public static final MetadataVersion IBP_0_10_2_IV0
public static final MetadataVersion IBP_0_11_0_IV0
public static final MetadataVersion IBP_0_11_0_IV1
public static final MetadataVersion IBP_0_11_0_IV2
public static final MetadataVersion IBP_1_0_IV0
public static final MetadataVersion IBP_1_1_IV0
public static final MetadataVersion IBP_2_0_IV0
public static final MetadataVersion IBP_2_0_IV1
public static final MetadataVersion IBP_2_1_IV0
public static final MetadataVersion IBP_2_1_IV1
public static final MetadataVersion IBP_2_1_IV2
public static final MetadataVersion IBP_2_2_IV0
public static final MetadataVersion IBP_2_2_IV1
public static final MetadataVersion IBP_2_3_IV0
public static final MetadataVersion IBP_2_3_IV1
public static final MetadataVersion IBP_2_4_IV0
public static final MetadataVersion IBP_2_4_IV1
public static final MetadataVersion IBP_2_5_IV0
public static final MetadataVersion IBP_2_6_IV0
public static final MetadataVersion IBP_2_7_IV0
public static final MetadataVersion IBP_2_7_IV1
public static final MetadataVersion IBP_2_7_IV2
public static final MetadataVersion IBP_2_8_IV0
public static final MetadataVersion IBP_2_8_IV1
public static final MetadataVersion IBP_3_0_IV0
public static final MetadataVersion IBP_3_0_IV1
public static final MetadataVersion IBP_3_1_IV0
public static final MetadataVersion IBP_3_2_IV0
public static final MetadataVersion IBP_3_3_IV0
public static final MetadataVersion IBP_3_3_IV1
public static final MetadataVersion IBP_3_3_IV2
public static final MetadataVersion IBP_3_3_IV3
public static final String FEATURE_NAME
public static final MetadataVersion MINIMUM_KRAFT_VERSION
public static final MetadataVersion MINIMUM_BOOTSTRAP_VERSION
public static final MetadataVersion[] VERSIONS
public static MetadataVersion[] values()
for (MetadataVersion c : MetadataVersion.values()) System.out.println(c);
public static MetadataVersion valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic short featureLevel()
public boolean isSaslInterBrokerHandshakeRequestEnabled()
public boolean isOffsetForLeaderEpochSupported()
public boolean isFeatureVersioningSupported()
public boolean isTruncationOnFetchSupported()
public boolean isAlterPartitionSupported()
public boolean isTopicIdsSupported()
public boolean isAllocateProducerIdsSupported()
public boolean isLeaderRecoverySupported()
public boolean isNoOpRecordSupported()
public boolean isKRaftSupported()
public org.apache.kafka.common.record.RecordVersion highestSupportedRecordVersion()
public boolean isBrokerRegistrationChangeRecordSupported()
public boolean isInControlledShutdownStateSupported()
public short registerBrokerRecordVersion()
public short fetchRequestVersion()
public short offsetForLeaderEpochRequestVersion()
public short listOffsetRequestVersion()
public String shortVersion()
public String version()
public boolean didMetadataChange()
public static MetadataVersion fromVersionString(String versionString)
public static MetadataVersion fromFeatureLevel(short version)
public static MetadataVersion minSupportedFor(org.apache.kafka.common.record.RecordVersion recordVersion)
public static MetadataVersion latest()
public static boolean checkIfMetadataChanged(MetadataVersion sourceVersion, MetadataVersion targetVersion)
public boolean isAtLeast(MetadataVersion otherVersion)
public boolean isLessThan(MetadataVersion otherVersion)
public String toString()
toString
in class Enum<MetadataVersion>