Pulsar：如果一条消息被 nack'd (negativeAcknowledge())，它什么时候会被重新发送？

Question

如果我们无法处理消息（可能是由于某些计时问题或竞争条件），我们调用

consumer.negativeAcknowledge(messageId);

什么时候重新提交重试处理？

我无法从文档中找出默认的交付设置

• https://pulsar.apache.org/docs/en/concepts-messaging/#negative-acknowledgement https://pulsar.apache.org/docs/en/concepts-messaging/#acknowledgement-timeout https://pulsar.apache.org/docs/en/reference-configuration/

Answer 1

默认为 60 秒。 您可以在消费者中配置它：

Consumer<byte[]> consumer = client.newConsumer()
    .topic("my-topic")
    .subscriptionName("my-sub")
    .negativeAckRedelivery(10, TimeUnit.SECONDS)
    .subscribe()