SpringBoot升级2.7后KafkaProducer与TracingKafkaProducer类型冲突问题

方案1：改用接口注入替代具体实现类 #

Spring Cloud Sleuth的TracingKafkaProducer实现了org.apache.kafka.clients.producer.Producer接口，而KafkaProducer是该接口的具体实现。把代码里的注入类型从KafkaProducer<K,V>改成Producer<K,V>，就能兼容代理类：

// 原错误写法
@Autowired
private KafkaProducer<String, Object> kafkaMigrationProducer;

// 修改后
@Autowired
private Producer<String, Object> kafkaMigrationProducer;

方案2：关闭Sleuth对Kafka的自动追踪 #

如果不需要Sleuth监控Kafka消息链路，直接在配置文件中禁用Kafka的自动增强：

# application.properties
spring.sleuth.instrumentation.kafka.enabled=false

或YAML格式：

# application.yml
spring:
  sleuth:
    instrumentation:
      kafka:
        enabled: false

方案3：统一依赖版本，修复兼容性 #

Spring Boot 2.7.x对应的Spring Cloud版本是2021.0.x（Jubilee版本），你当前用的Sleuth 3.1.0属于2020.0.x（Ilford版本），版本不匹配容易引发冲突。建议用Spring Cloud BOM统一管理版本，替换单独的Sleuth依赖：

<dependencyManagement>
  <dependencies>
    <!-- Spring Cloud 2021.0.x 适配Spring Boot 2.7.x -->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>2021.0.8</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>

<!-- 无需指定版本，由BOM统一控制 -->
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>

同时移除Spring Kafka的手动版本号，让Spring Boot父工程统一管理：

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
</dependency>

方案4：手动提取原始KafkaProducer实例 #

如果必须使用KafkaProducer类型，可以通过TracingKafkaProducer的getDelegate()方法获取原始实例：

import org.springframework.cloud.sleuth.instrument.kafka.TracingKafkaProducer;
import org.apache.kafka.clients.producer.KafkaProducer;

@Autowired
private Producer<String, Object> kafkaMigrationProducer;

// 获取原始生产者实例
private KafkaProducer<String, Object> getOriginalProducer() {
    if (kafkaMigrationProducer instanceof TracingKafkaProducer) {
        return (KafkaProducer<String, Object>) ((TracingKafkaProducer<String, Object>) kafkaMigrationProducer).getDelegate();
    }
    return (KafkaProducer<String, Object>) kafkaMigrationProducer;
}

内容的提问来源于stack exchange，提问作者by Jean