We are running into an issue where for failing message processing the messages are redelivered indefinitely. At first, we explicitly .negativeAcknowledge the messages. Then we tried to rely on the ackTimeout. Neither worked.
If we inspect the messages that are stuck in a loop we can see that they do not have a redeliveryCount set which we believe is leading to the infinite redelivery
Hello! We run Pulsar Consumer with:
We are running into an issue where for failing message processing the messages are redelivered indefinitely. At first, we explicitly
.negativeAcknowledge
the messages. Then we tried to rely on the ackTimeout. Neither worked.If we inspect the messages that are stuck in a loop we can see that they do not have a redeliveryCount set which we believe is leading to the infinite redelivery
Any help appreciated :)