在多个消费组并行消费同一 Kafka topic 且各写不同系统的场景下,若某个消费组偶发失败且不能重放整条消息,你会如何保证该组失败消息的精准重试与幂等?
考察说明
考察对 Kafka 消费语义、精准重试与幂等设计的理解
回答思路
- 能指出每条消息应有唯一业务 ID 或事件 ID
- 能说明失败消息进入专用重试队列或重试 topic 而非整体重放
- 能说明消费者需实现幂等写入或通过下游去重保证重复消费安全
- 能处理重试顺序、消息积压与并发消费的边界
本题已收录答题指导
本题附完整参考答案与评分标准
登录后可查看结构化答题指导;也可以直接开一场模拟面试,AI 面试官用本题实时追问并给出评分。