先看积压是怎么涨起来的:缓慢上涨多半是消费能力不够。
突然堆积说明是生产端突增或消费端卡住,去看消费速率和重试次数。
消费慢就扩消费者或批量拉取;消费端报错重试,先把毒消息挪到死信队列。
# 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






暂无评论内容