我正在编写需要快速访问某些资源的实时应用程序。我使用的是关系数据库和redis。我使用关系数据库安全地存储资源，使用redis快速访问这些资源。
我面临的问题是，维护这两个存储之间一致性的代码变得非常复杂。我需要检查是否正在写入这两个，如果其中一个失败，撤消一个工作。
我考虑过使用类似kafka的方法，将写入内容发送到特定主题，并使用不同的使用者（sqlconsumer和redisconsumer）写入相应的数据库。这样，消费者将无限期地重试，并最终实现一致性。理想情况下，在写入成功之前不会提交消息。
这是一种常见/正确的方法吗？有没有其他方法可以改进我的架构？