企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
由于consumer消费者出现了故障,message没有被及时消费,导致topic挤压了几百万甚至几千万的数据。 这种情况的解决方案通常是先修复consumer,再迅速消费完积压的消息。 1. 修复consumer程序,并停止消费 2. 新建数倍的topic或者数倍的queue 3. 积压的消息简单消费处理之后均匀写入新建的queue。注意消费速度,新建queue的数量,目的迅速消费积压的message 4. 临时调用数倍的服务器部署consumer程序,对queue进行消费 5. 处理完成之后恢复原来的部署架构