Hi, I'd like to start a discussion on KIP-628: ConsumerPerformance's multi-thread implementation.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-628%3A+ConsumerPerformance%27s+multi-thread+implementation It's about making option [threads] work in ConsumerPerformance whose implementation has been removed because new consumer replaced old consumer . If you have a moment please take a look Best wishes Jiamei Xie
