一句话承诺:一张图+配置示例,快速落地带延迟重试与死信处理的队列结构。

参数 | 说明 |
|---|---|
x-dead-letter-exchange | 死信交换机 |
x-message-ttl | 重试延迟 |
x-dead-letter-routing-key | 路由到主队列或死队列 |
ch.assertExchange('dlx', 'direct')
ch.assertQueue('main')
ch.assertQueue('retry', {
arguments: { 'x-dead-letter-exchange': 'dlx', 'x-message-ttl': 10000, 'x-dead-letter-routing-key': 'main' }
})
ch.assertQueue('dead')
ch.bindQueue('dead', 'dlx', 'dead')
ch.bindQueue('main', 'dlx', 'main')Kafka 消费组重平衡:offset 管理与再均衡观察(命令+图)。