Как обрабатывать сбой Apache Pulsar Consumer.acknowledgeAsync ()?

Question

Я использую Consumer.acknowledgeAsync () для подтверждения сообщений в моем Java-сервисе, и мне было интересно, что произойдет в случае сбоя подтверждения?Должен ли я повторить операцию несколько раз и отказаться от своего потребителя, когда повторные попытки исчерпаны?

Я считаю количество сообщений, обрабатываемых для управления потоком, чтобы ограничить использование памяти.

Answer 1

Обычно, если сообщение не было успешно подтверждено, после ackTimeout сообщение будет снова доставлено от брокера к потребителю.Так что здесь, в большинстве случаев, нет необходимости повторять попытку.

может быть, некоторой обработки, подобной этой, достаточно:

consumer.acknowledgeAsync(msgId)
    .thenAccept(consumer -> successHandlerMethod())
    .exceptionally(exception -> failHandlerMethod());