Cosmos DB Change Feed Processor多实例重复消费：已设LeasePrefix仍异常

嘿，我来帮你搞定这个重复处理数据的麻烦！你现在遇到的问题核心原因其实是LeasePrefix的设置逻辑搞反了，咱们一步步拆解解决：

问题根源分析 #

你把LeasePrefix设置成了每个实例的唯一ID（RoleEnvironment.CurrentRoleInstance.Id），这相当于把两个Worker实例变成了完全独立的消费组。每个消费组都会独立监听整个Cosmos DB集合的Change Feed，自然就会导致同一份数据被两个实例各自处理一遍，出现重复。

正确的逻辑是：同一个消费组内的所有实例，必须共享相同的LeasePrefix，这样Change Feed Processor才会自动把集合的分区租约分配给不同的实例，实现负载均衡；而每个实例的唯一标识应该用HostName来设置，用来标记哪个实例持有哪个分区的租约。

具体修复步骤 #

1. 统一LeasePrefix配置 #

把两个实例的LeasePrefix改成同一个固定值，比如你的应用名称或者消费组名称（比如"OrderProcessingConsumerGroup"），确保它们属于同一个消费组：

var hostOptions = new ChangeFeedHostOptions
{
    // 关键：两个实例用相同的前缀，标识同一消费组
    LeasePrefix = "OrderProcessingConsumerGroup",
    LeaseCollectionName = "your-lease-collection-name",
    // 其他配置保持不变
};

2. 用实例ID设置HostName #

每个实例的HostName设为唯一的实例ID，这样Processor能区分不同实例，正确分配租约：

var processor = new ChangeFeedProcessorBuilder()
    // 用实例ID作为HostName，标记实例身份
    .WithHostName(RoleEnvironment.CurrentRoleInstance.Id)
    .WithFeedCollection(yourFeedCollectionInfo)
    .WithLeaseCollection(yourLeaseCollectionInfo)
    .WithHostOptions(hostOptions)
    .WithProcessorFactory(async (context) => new YourChangeFeedProcessor())
    .Build();

3. 清理旧租约（可选但建议） #

因为之前用不同的LeasePrefix生成了大量独立租约，建议手动清理租约集合中属于旧前缀的租约文档，避免干扰新的租约分配逻辑。

4. 确认租约集合配置 #

确保租约集合是两个实例共享的，并且配置了足够的吞吐量（建议至少400 RU/s，根据实例数量调整），否则可能会导致租约更新不及时，影响负载均衡效果。

原理补充 #

• LeasePrefix：消费组的唯一标识，同一个消费组的实例必须使用相同的值，这样它们会共享租约集合中的同一组租约。
• HostName：实例的唯一标识，用来在租约中记录哪个实例持有该分区的租约，Processor会根据这个信息自动分配和转移租约。

这样调整后，两个Worker实例就会协作处理Change Feed，每个实例只会拿到部分分区的租约，不会再出现重复处理的问题啦！

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