Kafka 2.X中TopicAndPartition已弃用 低版本升级高版本如何修复

kafka.api.TopicAndPartition在Kafka 2.0版本被正式标记为弃用，后续高版本（2.2+）已完全移除该类，升级时的兼容问题可以根据不同使用场景选择以下修复方案：

• 【业务代码直接引用场景】直接替换为官方指定的替代类org.apache.kafka.common.TopicPartition即可，两个类的核心方法完全一致：
  原代码写法：new TopicAndPartition("testTopic", 1)
  替换后写法：new TopicPartition("testTopic", 1)
  原有调用topic()、partition()获取属性的逻辑不需要做任何修改。
• 【旧版低阶API依赖场景】如果你原来用SimpleConsumer等低阶API时用到TopicAndPartition，建议直接迁移到新版KafkaConsumer高级API：
  新版消费者原生使用TopicPartition作为分区标识类，直接调用assignment()、position()、commitSync()等方法即可完成偏移量查询、提交等操作，无需再手动维护分区标识类。
• 【框架/中间件兼容场景】如果你维护的是Kafka周边组件，需要同时兼容高低版本Kafka，可以做一层轻量兼容层：
  运行时通过反射判断当前环境的Kafka版本，低版本实例化TopicAndPartition，高版本实例化TopicPartition，对外暴露统一的getTopic()、getPartition()方法，避免编译时依赖冲突。
• 【第三方依赖未适配场景】如果你的项目依赖的第三方组件还在使用已移除的TopicAndPartition，优先升级第三方组件到适配高版本Kafka的版本；如果无法升级，可以在项目中临时新增和原类全路径（kafka.api.TopicAndPartition）完全一致的自定义类，实现和旧类相同的方法做过渡适配。

升级校验注意事项 #

• 升级后需要统一所有Kafka相关依赖（kafka-clients、kafka-core）的版本，避免混合版本依赖出现ClassNotFoundException、NoSuchMethodException等异常。
• 重点测试分区分配、偏移量提交、元数据查询三类逻辑，确保替换后业务逻辑无异常。

内容的提问来源于stack exchange，提问作者Vikram Reddy