在我的应用程序使用的mysql集群遇到一些瓶颈（连接太多、死锁太多）之后，有人建议我使用kafka或redis对所有写操作进行排队。一个近乎实时的解决方案听起来确实比在生产中出现数据库连接错误要好得多，所以我选择了这个建议。
然而，我很难理解Kafka（或者redis流）在我的架构中的位置。我目前使用多个mysql服务器，前面有一个haproxy，然后将读写查询拆分到不同的端口，以防止集群失去同步。然后将每个端口定向到一个服务器（对于写查询）或多个服务器（对于读查询）。
我假设我必须配置write端点，以便所有write查询都首先通过kafka，但似乎我知道的太少，无法根据我一直在看的教程来连接这些点（大多数示例都将某些mysql表转换为流，但对于我的用例来说，那就太晚了）。
我的问题是：有没有一种简单的方法将sql查询重定向到kafka（比如将mysql主机和端口配置切换到kafka或者使用某种插件）或者我必须编写自己的适配器？
（我的应用程序使用php和laravel）