Kafka 4.0 的共享组(Share Group)模式
Kafka 4.0 的共享组(Share Group)模式允许同一分区的消息被多个消费者并发消费,这一设计在提升资源利用率的同时,确实会引入锁竞争问题,但其通过**精细化锁机制与异步优化**实现了性能与并发的平衡。 --- ### 一、共享组模式的锁竞争与优化策略 1. **消息粒度的锁机制** • **时间锁(Invisible Time)**:Broker 为每条消息设置临时锁(如 30 秒),在此期间仅允许一个消费者处理该消息。若消费者未在锁定期内确认,消息将重新变为可见状态,供其他消费者消费。 • **异步提交偏移量**:消费者独立提交偏移量,Broker 端通过乐观锁(CAS)合并偏移量更新请求,减少同步锁操作频率。 2. **批量处理与时间轮优化** • **分层时间轮**:用于...阅读全文
