在Apache Kafka中,可以使用以下代码示例来获取inter.broker.protocol.version
后缀:
import org.apache.kafka.common.protocol.ApiKeys;
public class KafkaProtocolVersionExample {
public static void main(String[] args) {
String interBrokerProtocolVersion = ApiKeys.KAFKA_STORAGE_PROTOCOL_VERSION.latestVersion().toString();
String[] versionParts = interBrokerProtocolVersion.split("-");
String suffix = versionParts.length > 1 ? versionParts[1] : "";
System.out.println("inter.broker.protocol.version suffix: " + suffix);
}
}
在这个例子中,我们使用了org.apache.kafka.common.protocol.ApiKeys
类中的KAFKA_STORAGE_PROTOCOL_VERSION.latestVersion()
方法,该方法返回了当前Kafka版本的最新协议版本。然后,我们将返回的版本转换为字符串,并使用-
作为分隔符将其分割成多个部分。最后,我们检查版本是否包含后缀部分,并将其打印出来。
请注意,这个示例假设您已经将Kafka相关的依赖项添加到您的项目中。您可以使用Maven或Gradle等构建工具来添加这些依赖项。