KIP-16 — Automated Replica Lag Tuning

Accepted BrokerProducer

Replaces replica.lag.max.messages with time-only ISR eligibility via replica.lag.time.max.ms: a replica is dropped from ISR if it has not caught up to the leader's log end offset within the configured time window. Measuring ISR lag in message count caused high-volume topics to experience spurious ISR shrinks on every large batch (e.g., a single batch exceeding the threshold), while low-volume topics detected dead replicas very slowly.

Details