【后端高阶面经：消息队列篇】23、Kafka耽误消息：实现高并发场景下的耽误使命处置惩罚

一、耽误消息的核心价值与Kafka的范围性

在分布式系统中，耽误消息是实现异步耽误使命的核心本领，广泛应用于订单超时取消、库存主动开释、消息重试等场景。
然而，Apache Kafka作为高吞吐的分布式消息队列，原生并不支持耽误消息功能，需通过业务层或中心层逻辑实现。
1.1 耽误消息的范例应用场景

  

• 订单超时取消：用户下单后30分钟未付出，主动取消订单并开释库存。  
  
• 消息重试机制：消耗失败的消息耽误5分钟后重新投递，制止立刻重试导致的资源竞争。  
  
• 异步关照优化：注册乐成后耽误1小时发送个性化保举邮件，提拔用户体验。
  

1.2 Kafka的范围性分析

  

• 无内置耽误队列：Kafka的消息消耗基于分区次序，无消息调治功能。  
  
• 时间戳仅作元数据：消息时间戳（timestamp）仅用于纪录消息天生时间，无法直打仗发耽误消耗。  
  
• 消耗者被动拉取：消耗者需主动轮询分区，无法根据消息耽误时间主动推送。 <