Hello Every one, I am have a scenario like where I am getting a message from kafka consumer which need to be persisted into DATABASE successfully, During this process there might be a chance of system crash/database crash/DB connection lost/some other exception which leads to this transaction persistence failure and the message becomes not operated, as the kafka offset is already committed so we are loosing the message.

Please provide me solution to handle such scenario with some examples.

Thanks,
Shashi.