How should Apache Pulsar Consumer.acknowledgeAsync() failure be handled?

Question

I am using Consumer.acknowledgeAsync() to ack messages in my Java service and was wondering what happens if the ack fails? Should I retry the operation a few times and discard my consumer when retries are exhausted?

I am counting the number of messages being processed for flow-control to limit memory usage.

It depends, right? If there were a one-size-fits-all solution, they wouldn't make you handle it yourself; they'd just, y'know, do it. — Michael
– Michael, Commented Dec 10, 2018 at 11:20

Jia Zhai · Accepted Answer · 2018-12-10 12:23:20Z

4

Usually, If message was not ack-ed successfully, after ackTimeout, the message will be redelivered from broker to consumer again. So here, most of the case, it is no need to retry.

maybe some handling like this is enough:

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

answered Dec 10, 2018 at 12:23

Jia Zhai

562 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

David Tinker Over a year ago

Re-delivery is fine in my case (flow control) so I can just count the message as acknowledged and assume it will work

Collectives™ on Stack Overflow

How should Apache Pulsar Consumer.acknowledgeAsync() failure be handled?

1 Answer 1

1 Comment

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Linked

Related