[ https://issues.apache.org/jira/browse/KAFKA-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138159#comment-17138159 ]
jiamei xie commented on KAFKA-10136: ------------------------------------ [~chia7712] Thanks. I am applying for permission to create KIP. If the option [numberMessages] is "total messages to consume for all threads", then an atomic variable is needed to synchronize how many messages have been consumed by all threads and poor performance will be achieved. > Make option threads of ConsumerPerformance work > ----------------------------------------------- > > Key: KAFKA-10136 > URL: https://issues.apache.org/jira/browse/KAFKA-10136 > Project: Kafka > Issue Type: Bug > Reporter: jiamei xie > Assignee: jiamei xie > Priority: Major > > Make option threads of ConsumerPerformance work -- This message was sent by Atlassian Jira (v8.3.4#803005)