Apache Pulsar：Negative Acknowledge与Retry策略共存的消息流转咨询

核心问题 #

• 同时配置Negative Acknowledge（Nack）和重试策略时会发生什么？
• Nack与重试主题策略是互斥还是可协同工作？
• 持续Nack消息或未及时Ack时，单条消息的失败流转过程是怎样的？

配置示例（.NET Pulsar.Client） #

var consumer = _client.NewConsumer()
    .SubscriptionType(SubscriptionType.KeyShared)
    .SubscriptionName(_config.SubscriptionName)
    .Topic(MyTopicName)
    .SubscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
    .ReceiverQueueSize(_config.BatchSize.Value)
    .AckTimeout(TimeSpan.FromMinutes(2))
    .AckTimeoutTickTime(TimeSpan.FromMinutes(2))
    .EnableRetry(true)
    .NegativeAckRedeliveryDelay(TimeSpan.FromSeconds(2))
    .DeadLetterPolicy(new DeadLetterPolicy(maxRedeliveryCount: 3))
    .SubscribeAsync();

解答 #

Nack与重试主题策略并非互斥，完全可以协同工作，具体行为和消息流转如下：

1. 主动调用Nack的流转过程

当消费者主动对消息执行Nack操作时：

• 消息不会直接回退到原主题，而是先被发送到对应订阅的重试主题（命名格式为原主题名-订阅名-retry）。
• 等待NegativeAckRedeliveryDelay配置的延迟时间后，重试主题会将消息重新投递到当前订阅的消费者。
• 每一次Nack都会使消息的重试计数加1，当计数达到DeadLetterPolicy中maxRedeliveryCount的阈值（示例中为3）时，消息会被转发到死信主题（命名格式为原主题名-订阅名-dlq），不再参与后续重试。

2. 未及时Ack触发AckTimeout的流转过程

当消息超过AckTimeout配置的时间未被确认时：

• Pulsar会自动触发消息的重试逻辑，同样将消息发送到重试主题，等待AckTimeoutTickTime配置的检测周期完成后，将消息重新投递到消费者。
• 后续的重试计数累加、死信主题流转逻辑，和主动Nack的场景完全一致。

关键说明

重试主题是Pulsar统一处理消息重试的底层机制，Nack只是触发重试的主动触发方式，而AckTimeout是被动触发方式——两者都依赖重试主题来实现消息的延迟重投，最终通过死信策略限制重试次数，避免消息无限循环。

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