Pulsar：如果一条消息被喃喃自语(负确认())，它什么时候会被重新传递？

Question

如果我们不能处理消息(可能是由于一些计时问题或竞争条件)，我们调用

consumer.negativeAcknowledge(messageId);

何时重新发送以重试处理?

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

• https://pulsar.apache.org/docs/en/concepts-messaging/negative-acknowledgementhttps://pulsar.apache.org/docs/en/concepts-messaging/#acknowledgement-timeouthttps://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()