使用Spring Cloud Stream Azure Event Hubs Binder如何自定义消息ID头

你不需要尝试修改Spring Message自带的只读id头（这是Spring框架内部用于消息跟踪的标识，设计为不可修改），而是可以通过以下两种方式，将自定义ID映射到Azure Event Hubs原生消息的MessageId属性，满足系统要求：

方案1：配置头映射实现自定义ID #

通过Spring Cloud Stream的头映射配置，将自定义头映射到Event Hubs的MessageId属性：

1. 在配置文件（如application.yml）中添加生产者头映射规则：

spring:
  cloud:
    stream:
      azure:
        eventhubs:
          bindings:
            # 替换成你的输出绑定名称，比如"output"
            your-output-binding-name:
              producer:
                header-mapping:
                  # 将自定义头custom-message-id映射到Event Hubs的message-id属性
                  custom-message-id: message-id

2. 在代码中设置自定义头：

MessageBuilder.withPayload(myPayload)
              .setHeader("custom-message-id", "myCustomIdHeaderValue")
              .build();

Binder会自动将custom-message-id的值同步到Event Hubs消息的MessageId字段。

方案2：自定义消息处理器直接修改原生EventData #

如果需要更灵活的控制，可以通过EventHubMessageCustomizer直接操作底层的Event Hubs消息对象：

1. 创建自定义的消息处理器Bean：

import com.azure.messaging.eventhubs.EventData;
import org.springframework.cloud.stream.azure.eventhubs.EventHubMessageCustomizer;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

@Component
public class CustomMessageIdSetter implements EventHubMessageCustomizer {

    @Override
    public void customize(EventData eventData, Message<?> message) {
        // 从消息头获取自定义ID，也可以直接硬编码或从其他来源获取
        String customId = (String) message.getHeaders().get("custom-message-id");
        eventData.setMessageId(customId);
    }
}

2. 在生产消息时设置自定义头：

MessageBuilder.withPayload(myPayload)
              .setHeader("custom-message-id", "myCustomIdHeaderValue")
              .build();

这个方式会在消息发送前直接修改Event Hubs的原生EventData对象，设置MessageId属性，完全绕过Spring的只读头限制。

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