我有三个消费者在不断地查询数据。使用者在将消耗的消息发送到其他应用程序之前，会消耗数据、执行一些验证并将消息偏移量和少量消息详细信息持久化到数据库中。如果我的数据库坏了，我该怎么处理我的消息呢？一旦数据库启动并运行，在不丢失数据的情况下恢复消息处理的可能解决方案是什么？