启用分区与重复检测的Azure Service Bus主题死信消息重提交报错

问题核心 #

报错明确要求：启用分区和重复检测的Service Bus主题，发送消息时必须设置PartitionKey或MessageId。你虽然代码中设置了这两个属性，但仍报错的原因大概率是：直接通过new ServiceBusMessage(dlqMessage)复制死信消息时，系统级属性的复制覆盖了后续设置的属性，或者部分消息未被正确赋值。

解决方案 #

1. 手动复制消息内容，避免系统属性干扰

不要直接用死信消息构造新消息，而是手动复制消息体和自定义属性，再显式设置MessageId和PartitionKey：

// 仅复制消息体，避免继承死信消息的系统属性
var resubmitMessage = new ServiceBusMessage(dlqMessage.Body)
{
    // 用Guid生成唯一MessageId，满足重复检测要求
    MessageId = Guid.NewGuid().ToString(),
    // 用Guid生成PartitionKey，比Random更避免重复
    PartitionKey = Guid.NewGuid().ToString()
};

// 按需复制自定义业务属性（如果需要保留原消息的业务标识）
foreach (var prop in dlqMessage.ApplicationProperties)
{
    resubmitMessage.ApplicationProperties[prop.Key] = prop.Value;
}

2. 确保所有返回消息都完成属性设置

检查ProcessDeadLetterMessagesAsync方法，确认每一条添加到result列表的消息都已正确设置MessageId和PartitionKey，不存在分支遗漏的情况。比如：是否有部分消息在处理时跳过了属性设置逻辑？

3. 验证绑定与权限配置

• 确认ServiceBusOutput特性的EntityType确实为ServiceBusEntityType.Topic，目标主题名称partstatus正确
• 检查连接字符串对应的Service Bus权限是否包含发送权限

额外调试建议 #

在设置属性后添加日志，验证属性是否被正确赋值：

_logger.LogInformation("Resubmit message - MessageId: {MsgId}, PartitionKey: {PKey}", 
    resubmitMessage.MessageId, resubmitMessage.PartitionKey);

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