KIP-72 — Allow putting a bound on memory consumed by Incoming request

Accepted Kafka 1.0 Broker

Introduces queued.max.request.bytes, a byte-level memory cap on the broker's incoming request queue, complementing the existing queued.max.requests count limit. The count-based limit cannot prevent OOM errors when a burst of large requests (e.g., from Hadoop) simultaneously exhausts JVM heap before the count threshold is reached.

Details