Always ack message to move the consumer offset forward.
Why Are Changes Being Made
Please validate my assumption If you must ack the message to move the consumer offset regardless of a failure, you can potentially queue the system forever when a loss is expected.
The failures are being logged today, so it should be good from that end.
The final solution would be to move the message into A DLQ (Dead-Letter Queue) in the case of a failure.
Changes
Always
ack
message to move the consumer offset forward.Why Are Changes Being Made
Please validate my assumption If you must
ack
the message to move the consumer offset regardless of a failure, you can potentially queue the system forever when a loss is expected.The failures are being logged today, so it should be good from that end.
The final solution would be to move the message into A DLQ (Dead-Letter Queue) in the case of a failure.