Kafka 2.4.0迁移至3.4.0遇兼容问题，求官方升级指南

针对 kafka.server.NotRunning 移除的处理 #

• 该异常类在 Kafka 3.0+ 版本中被移除，官方替换为标准的 org.apache.kafka.common.errors.NotRunningException。
• 代码修改步骤：
  1. 将原导入语句 import kafka.server.NotRunning; 替换为 import org.apache.kafka.common.errors.NotRunningException;。
  2. 所有捕获或抛出 NotRunning 的逻辑，直接替换为 NotRunningException 即可，异常行为保持一致。

针对 kafka.server.KafkaConfig.port() 方法移除的处理 #

• 旧版本的 port() 仅返回单个端口，但 Kafka 3.0+ 支持多监听器配置，因此官方移除了该单端口方法，改为通过监听器配置获取对应端口。
• 代码修改示例：
  若你需要获取默认PLAINTEXT监听器的端口：

  import org.apache.kafka.common.config.KafkaConfig;
  import org.apache.kafka.common.utils.Utils;
  
  KafkaConfig kafkaConfig = ...; // 你的配置实例
  String listeners = kafkaConfig.getString(KafkaConfig.LISTENERS_CONFIG);
  
  // 解析第一个监听器的端口（可根据实际需求调整监听规则）
  String firstListenerUrl = listeners.split(",")[0];
  int port = Utils.parsePort(firstListenerUrl);
  

  若需要特定类型的监听器端口（如SSL）：

  import org.apache.kafka.common.network.ListenerName;
  import org.apache.kafka.common.security.auth.SecurityProtocol;
  
  List<ListenerName> listenerNames = kafkaConfig.listeners();
  ListenerName sslListener = new ListenerName(SecurityProtocol.SSL.name());
  
  if (listenerNames.contains(sslListener)) {
      String sslListenerUrl = kafkaConfig.getListenerEndpoint(sslListener).connectionString();
      int sslPort = Utils.parsePort(sslListenerUrl);
  }
  

通用升级建议 #

• 避免跨大版本直接升级：建议先从2.4.0升级到2.8.x（LTS版本），再逐步升级到3.0.x、3.4.0，每一步都验证集群稳定性。
• 重点查阅每个中间版本的官方变更日志：关注核心API、配置项的移除/替换说明，这是处理破坏性变更最权威的依据。
• 测试环境充分验证：生产升级前，务必在测试环境完整跑通所有业务代码和集群配置，确保兼容性。

内容的提问来源于stack exchange，提问作者Daniel Goers