conduktor.io ↗

KIP-628 — ConsumerPerformance's multi-thread implementation

Discussion Consumer

Restores multi-thread support to `kafka-consumer-perf-test.sh` by implementing a `ConsumerPerfThread` class for the new consumer API, making the `--threads` option functional again. Multi-thread consumer performance testing was removed when the tool was migrated from the old consumer to the new consumer API, leaving no way to benchmark consumer throughput with multiple threads.

Details

AuthorJiamei.xie
StatusDiscussion
JIRAKAFKA-10136
WikiView on Apache Wiki
Created2020-06-18
Last Modified2020-07-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.