后端岗位面试题更新 2026-08-05

Kafka中一直消费失败的消息,导致后面的消息都阻塞了,怎么处理?

58到家后端开发消费品/零售风险判断方案权衡问题排查Apache Kafka

考察说明

考察对Kafka消费机制、失败重试策略和消息堆积治理的理解

回答思路

  1. 识别阻塞根因:单条消息处理抛出异常导致消费线程退出或偏移量不提交
  2. 阐述隔离失败消息与正常消息的处理策略
  3. 说明死信队列、重试队列或延迟重试的实现方式
  4. 讨论消费位移提交方式与幂等性保障
本题已收录答题指导

本题附完整参考答案与评分标准

登录后可查看结构化答题指导;也可以直接开一场模拟面试,AI 面试官用本题实时追问并给出评分。