频繁的 Rebalance 会导致消费停顿与重复消费。引入**静态成员(Static Membership)**并合理设置 session.timeout.ms 与 max.poll.interval.ms 可显著抑制风暴。
![]()
一、静态成员与超时配置
properties
# 消费者配置
group.instance.id=consumer-pod-1
session.timeout.ms=45000
heartbeat.interval.ms=3000
max.poll.interval.ms=300000
partition.assignment.strategy=org.apache.kafka.clients.consumer.CooperativeStickyAssignor