如何解决Kafka生产者日志未携带已设置MDC值的问题

MDC底层基于ThreadLocal实现，存储的上下文数据仅和当前执行线程绑定，不会自动在线程间传递。从日志线程名可以明确看到：

• 控制器接口逻辑运行在Tomcat内置请求线程nio-8080-exec-2上，该线程内设置的correlationId可以正常打印
• Kafka生产者的发送逻辑、回调逻辑运行在独立业务线程池的rest-services-1线程上，这个线程没有继承原请求线程的MDC数据，所以打印日志时MDC字段为空。

根据你的线程池使用场景，选对应方案即可：

1. 自定义业务线程池配置自动透传MDC #

如果rest-services-1是项目自定义封装的线程池（用于异步执行Kafka发送等逻辑），不需要在每个业务方法里手动传值，直接给线程池配置任务装饰器，自动完成MDC上下文的拷贝和清理：

/**
 * 线程池任务装饰器，自动在提交任务时拷贝主线程MDC上下文，子线程执行时注入，执行完清理
 */
public class MdcTaskDecorator implements TaskDecorator {
    @Override
    public Runnable decorate(Runnable runnable) {
        // 提交任务时先捕获当前线程的MDC副本
        Map<String, String> originContext = MDC.getCopyOfContextMap();
        return () -> {
            try {
                // 子线程执行前注入MDC上下文
                if (originContext != null) {
                    MDC.setContextMap(originContext);
                }
                runnable.run();
            } finally {
                // 任务执行完成后清理子线程MDC，避免线程复用时上下文串扰
                MDC.clear();
            }
        };
    }
}

把装饰器注册到你的业务线程池即可，以Spring的ThreadPoolTaskExecutor为例：

@Bean("restServicesExecutor")
public ThreadPoolTaskExecutor restServicesExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(8);
    executor.setMaxPoolSize(16);
    executor.setQueueCapacity(1000);
    executor.setThreadNamePrefix("rest-services-");
    // 注册MDC透传装饰器
    executor.setTaskDecorator(new MdcTaskDecorator());
    executor.initialize();
    return executor;
}

如果项目里用的是普通JDK线程池，也可以在提交Runnable/Callable时手动套用上述拷贝逻辑，原理完全一致。

2. Kafka客户端原生线程场景处理 #

如果Kafka发送逻辑用的是Kafka客户端自带的内部线程，没法直接修改其线程池配置，就在调用发送方法前手动取出当前线程的correlationId，在回调逻辑里手动注入MDC：

// 调用send方法前先从当前请求线程取出correlationId
final String correlationId = MDC.get("correlationId");
kafkaProducer.send(producerRecord, (metadata, exception) -> {
    try {
        // 回调执行前手动设置MDC值
        MDC.put("correlationId", correlationId);
        if (exception == null) {
            log.info("Message successfully delivered");
            log.info("Event sent to bpm topic  EventCode: {}", eventCode);
        } else {
            log.error("Message send failed", exception);
        }
    } finally {
        MDC.remove("correlationId");
    }
});

3. 修正MDC清理时机避免提前清空 #

你当前在拦截器的postHandle方法里执行MDC.clear()，这个触发时机是在控制器方法执行完成、视图渲染前，此时如果Kafka发送是异步提交的，很可能任务还没来得及拷贝MDC上下文，就被请求线程提前清空了。建议把MDC清理逻辑挪到拦截器的afterCompletion方法中执行，确保所有异步任务提交完成后再清理请求线程的MDC：

@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, 
                            Object handler, Exception ex) {
    MDC.clear();
}

配置完成后重启服务，所有线程打印的日志都会携带一致的correlationId字段。

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