Kafka 2.7升级3.0时KafkaServerStartable类缺失的解决方案问询

从Kafka 2.8版本开始官方就废弃了KafkaServerStartable，2.8.1版本正式移除后，统一使用 kafka.server.Kafka 作为Broker的标准启动入口，完全覆盖原有类的所有能力，具体适配方式如下：

1. 嵌入式启动Broker的代码适配 #

原有使用KafkaServerStartable的启动逻辑可直接替换，示例如下：
原有写法

import kafka.server.KafkaServerStartable;

KafkaServerStartable startable = new KafkaServerStartable(serverConfig);
startable.startup();
// 关闭逻辑
startable.shutdown();
startable.awaitShutdown();

新版本写法

import kafka.server.Kafka;
import kafka.server.Server;

// 直接传入服务端配置Properties构建实例
Server kafkaServer = Kafka.fromProps(serverProps);
kafkaServer.startup();
// 原有关闭逻辑保持一致
kafkaServer.shutdown();
kafkaServer.awaitShutdown();

2. 自定义启动脚本适配 #

如果你是直接调用Java主类启动Kafka进程，将原主类全限定名 kafka.server.KafkaServerStartable 替换为 kafka.Kafka 即可，入参规则不变，依然是直接传入server.properties配置文件路径。

注意事项 #

• Kafka类天生兼容ZK和KRaft两种部署模式，无需额外做分支适配，框架会根据你传入的配置自动识别运行模式
• 如果需要获取原KafkaServerStartable暴露的服务配置、运行时实例等信息，可将返回的Server接口实例强转为对应实现类：ZK模式下为kafka.server.KafkaServer，KRaft模式下为kafka.server.BrokerServer
• 依赖引入时要保证你项目中依赖的Kafka内核包版本和你升级的服务端版本完全一致，避免出现类不兼容问题

内容的提问来源于stack exchange，提问作者Aditya Jain