Kafka 消费组、位点与消息语义
消息队列与搜索#Kafka消费组#位点#消息语义约 534 字 · 2 分钟阅读
追问显示点击任意追问卡片可收起 / 展开
Consumer Group 的作用是什么？
追问 同组消费与不同组消费同一个 Topic 时，分区分配和处理范围有什么差异？
在常规 Consumer Group 模式下，消费者多于分区会怎样？
追问 为什么单纯增加消费者数量不一定能提升吞吐？
Kafka Offset 表示什么？
追问 消息在分区中的位置、消费者当前处理位置和已提交位点如何区分？
自动提交与手工提交位点有什么区别？
追问 在业务处理前或后提交，分别可能造成什么丢失或重复？
Consumer Lag 应如何计算和解读？
追问 消息条数积压与时间延迟有什么区别，为什么还需查看消费进展与消息大小？
消费组为什么发生 Rebalance？
追问 实例增减、心跳失败、处理超时和分区变化分别如何触发调整？
消费者频繁 Rebalance，你会如何排查？
追问 poll 间隔、处理耗时、心跳、垃圾回收、网络和配置如何分析？
重置消费位点前，必须确认哪些信息？
追问 目标范围、消费组状态、重复副作用、保留数据和原位点如何记录与验证？
Producer 幂等性和事务分别能提供什么保障？
追问 保障范围、客户端配置与外部数据库写入之间有哪些边界？
同一个业务 Key 的消息需要按顺序处理，应如何设计？
追问 分区策略、分区扩容、消费者并发、失败重试和处理完成顺序如何考虑？