i am consuming messages from pubsub topic in spark-scala streaming code. i need to send the acknowledgement of messages after the processing is completed. is there any way we can do it in spark?

current with “autoAcknowledgement=true”, it is sending the acknowledgement as soon as it receives. but if my application failed before prcoessing that message then i am losing that message.

how i can send acknowledgement after the processing of the message and not before in spark-scala.

kindly help me on this