在 Kafka 中,如何保证消息不丢失?请从生产者、Broker 和消费者三个层面说明。
考察说明
考察对 Kafka 消息可靠性机制的系统性理解
回答思路
- 生产者端:设置 acks=all 并开启重试,确保消息成功写入
- Broker 端:设置 replication.factor>=3,并启用 unclean.leader.election=false
- 消费者端:关闭自动提交位移,处理成功后手动提交
- 能说明不同配置对性能和可靠性的取舍
本题已收录答题指导
本题附完整参考答案与评分标准
登录后可查看结构化答题指导;也可以直接开一场模拟面试,AI 面试官用本题实时追问并给出评分。