后端岗位面试题更新 2026-08-05
Kafka中一直消费失败的消息,导致后面的消息都阻塞了,怎么处理?
58到家后端开发消费品/零售风险判断方案权衡问题排查Apache Kafka
考察说明
考察对Kafka消费机制、失败重试策略和消息堆积治理的理解
回答思路
- 识别阻塞根因:单条消息处理抛出异常导致消费线程退出或偏移量不提交
- 阐述隔离失败消息与正常消息的处理策略
- 说明死信队列、重试队列或延迟重试的实现方式
- 讨论消费位移提交方式与幂等性保障
本题附完整参考答案与评分标准
登录后可查看结构化答题指导;也可以直接开一场模拟面试,AI 面试官用本题实时追问并给出评分。