conduktor.io ↗

KIP-402 — Improve fairness in SocketServer processors

Accepted Kafka 2.2 Broker

Changes SocketServer's Processor threads to interleave processing of new and existing connections rather than draining all new connections first. Under connection storms, the old behavior blocked existing connections from being processed until the storm subsided, causing memory buildup and response latency spikes for established clients.

Details

AuthorRajini Sivaram
StatusAccepted
Kafka Version2.2
JIRAKAFKA-7719
WikiView on Apache Wiki
Created2018-12-11
Last Modified2019-01-21
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.