Hi, I'd like to start 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 IMPORTANT NOTICE: The contents of this email and any attachments are confidential and may also be privileged. If you are not the intended recipient, please notify the sender immediately and do not disclose the contents to any other person, use it for any purpose, or store or copy the information in any medium. Thank you.