发送至RabbitMQ Exchange的消息无法路由至绑定队列求助

针对pg-bifrost的问题修复 #

核心原因 #

pg-bifrost虽无需手动配置路由键，但会自动生成固定格式的路由键发送至topic exchange。你的队列绑定路由键与工具生成的不匹配，导致消息不可路由；而desiredCount递增是因为RabbitMQ未返回消息确认，工具一直在等待回执。

修复步骤 #

1. 确认pg-bifrost的路由键规则
   查看pg-bifrost源码或添加--log-level debug启动参数开启debug日志，找到它生成路由键的逻辑。通常这类工具会用<数据库模式>.<表名>（比如public.your_table）或直接用表名作为路由键。
2. 调整队列绑定的路由键
   在RabbitMQ管理界面修改队列test与exchangeex的绑定关系：
   • 若工具用public.your_table，绑定路由键设为public.your_table
   • 若需topic模式匹配，也可使用通配符（比如*.your_table或public.*）
3. 验证消息投递
   修改PostgreSQL表数据后，查看RabbitMQ队列的消息数，同时检查工具日志是否不再出现Waiting for desired confirms count的持续递增情况。
4. 清理不可路由消息
   在RabbitMQ管理界面的"Exchanges"页面，找到ex，点击"Unroutable messages"清理积压的不可路由消息。

无代码替代方案 #

如果pg-bifrost的限制无法满足需求，推荐以下工具：

• Debezium：
  基于CDC（变更数据捕获）的成熟工具，支持PostgreSQL到RabbitMQ的无代码配置。可通过Docker快速部署，通过配置文件指定监听表、exchange类型、路由键规则，全程无需编写代码。
• Node-RED：
  可视化低代码平台，拖放PostgreSQL Change Stream节点和RabbitMQ Out节点即可实现变更转发，无需复杂编码，适合快速搭建原型。
• 云数据管道服务：
  如AWS DMS、Google Cloud Dataflow，通过控制台配置数据同步任务，从PostgreSQL捕获变更并发送到RabbitMQ，全程可视化操作，无需代码。

内容的提问来源于stack exchange，提问作者yaras_phoenix