如何在Spring Cloud Stream中移除DLQ消息的x-exception-stacktrace头？

方案一：通过配置属性控制重发头 #

Spring Cloud Stream RabbitMQ 支持通过配置指定重发至DLQ时携带的消息头，你可以在原有配置的rabbit.default.consumer节点下添加以下配置，排除不需要的x-exception-stacktrace头：

spring:
  cloud:
    stream:
      rabbit:
        default:
          consumer:
            # 方式1：只保留指定必要头，自动排除x-exception-stacktrace
            republish-headers: "x-death,content-type"
            # 方式2：用正则表达式排除特定头（二选一即可）
            # republish-headers-pattern: "^(?!x-exception-stacktrace).*$"

说明：

• republish-headers：明确指定重发时需要携带的头列表，仅保留业务必要的头即可，x-exception-stacktrace不会被带入DLQ消息。
• republish-headers-pattern：通过正则表达式匹配允许的头，^(?!x-exception-stacktrace).*$表示排除所有名为x-exception-stacktrace的头。

方案二：自定义错误消息处理策略 #

如果配置属性无法满足灵活需求，可自定义错误消息处理逻辑，覆盖默认的死信头构建行为：

1. 创建自定义策略类，继承默认的死信头处理类：

import org.springframework.cloud.stream.binder.rabbit.DlqMessageHeaderErrorMessageStrategy;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;

public class CustomDlqErrorMessageStrategy extends DlqMessageHeaderErrorMessageStrategy {

    @Override
    protected Message<?> buildErrorMessage(Message<?> originalMessage, Throwable throwable) {
        Message<?> errorMessage = super.buildErrorMessage(originalMessage, throwable);
        // 主动移除x-exception-stacktrace头
        return MessageBuilder.fromMessage(errorMessage)
                .removeHeader("x-exception-stacktrace")
                .build();
    }
}

2. 将自定义策略注册为Spring Bean：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public CustomDlqErrorMessageStrategy customDlqErrorMessageStrategy() {
        return new CustomDlqErrorMessageStrategy();
    }
}

这样消息被重发至DLQ时，x-exception-stacktrace头会被自动移除，避免消息体积持续膨胀。

额外说明 #

你之前尝试的frameMaxHeadroom是用于调整RabbitMQ的帧头预留空间，和消息头的内容过滤无关，因此无法解决该问题。建议优先使用方案一，通过配置快速生效；若需要更复杂的头处理逻辑，再采用方案二。

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