conduktor.io ↗

KIP-281 — ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User

Accepted Kafka 2.0 Consumer

KIP-281 increases the default `kafka-consumer-perf-test.sh` polling loop timeout from 1 second to 10 seconds and exposes it as a configurable `--timeout` command-line parameter. On topics with large partition counts, iterating over polled batches takes longer than 1 second, causing the benchmark tool to exit prematurely and report far fewer consumed records than actually exist.

Details

AuthorAlex Dunayevsky
StatusAccepted
Kafka Version2.0
JIRAKAFKA-6743
WikiView on Apache Wiki
Created2018-04-04
Last Modified2018-06-09
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.