消息队列大量积压,先分清是消费太慢还是生产突增

先看积压是怎么涨起来的:缓慢上涨多半是消费能力不够。

突然堆积说明是生产端突增或消费端卡住,去看消费速率和重试次数。

消费慢就扩消费者或批量拉取;消费端报错重试,先把毒消息挪到死信队列。

# RabbitMQ:看积压和未确认数
rabbitmqctl list_queues name messages messages_ready messages_unacknowledged
# Kafka:看每个分区的 lag
kafka-consumer-groups.sh --bootstrap-server broker:9092 --describe --group order-consumer
# 队列声明时挂死信交换机
x-dead-letter-exchange=dlx.orders
THE END
喜欢就支持一下吧
点赞6 分享
评论 抢沙发

请登录后发表评论

    暂无评论内容