public enum MetadataVersion extends Enum<MetadataVersion>
Modifier and Type | Field and Description |
---|---|
static String |
APACHE_FEATURE_NAME |
static String |
CONFLUENT_FEATURE_NAME |
static String |
CONFLUENT_RELEASE_PREFIX |
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 |
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 MetadataVersion IBP_3_4_IV0
public static final String APACHE_FEATURE_NAME
public static final String CONFLUENT_FEATURE_NAME
public static final String CONFLUENT_RELEASE_PREFIX
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 apacheFeatureLevel()
public short confluentFeatureLevel()
public boolean isSaslInterBrokerHandshakeRequestEnabled()
public boolean isOffsetForLeaderEpochSupported()
public boolean isMinTierFeatureSupported()
public boolean isFeatureVersioningSupported()
public boolean isTruncationOnFetchSupported()
public boolean isAlterPartitionSupported()
public boolean isTopicIdsSupported()
public boolean isAllocateProducerIdsSupported()
public boolean isLeaderRecoverySupported()
public boolean isNoOpRecordSupported()
public boolean isApiForwardingEnabled()
public boolean isKRaftSupported()
public org.apache.kafka.common.record.RecordVersion highestSupportedRecordVersion()
public boolean isBrokerRegistrationChangeRecordSupported()
public boolean isInControlledShutdownStateSupported()
public boolean isMigrationSupported()
public boolean isClusterLinkModeSupported()
public short clusterLinkRecordVersion()
public boolean isLinkCoordinatorEnabled()
public short registerBrokerRecordVersion()
public short fetchRequestVersion()
public short offsetForLeaderEpochRequestVersion()
public short listOffsetRequestVersion()
public String shortVersion()
public String version()
public String shortConfluentRelease()
public String confluentRelease()
public String apacheRelease()
public boolean didMetadataChange()
public static MetadataVersion fromVersionString(String versionString)
public static MetadataVersion fromConfluentFeatureLevel(short version)
public static MetadataVersion fromApacheFeatureLevel(short level)
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>