THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
kafka.tools.ConsumerPerformance is used in kafka-consumer-perf-test.sh. This KIP is to make option [threads] work.
Proposed Changes
Describe the new thing you want to do in appropriate detail. This may be fairly extensive and have large subsections of its own. Or it may be a few sentences. Use judgement based on the scope of the change.
...
We define a new class ConsumerPerfThread in ConsumerPerformance to implement multi-thread, which is not a public interface.
| Attribute | Description |
|---|---|
| threadId : Int | The thread Id. |
| config : ConsumerPerfConfig | The configuration of ComsumerPerformance |
| totalMessagesRead : LongAdder | The total number of messages which have been read |
| totalBytesRead : LongAdder | The total byte of messages which have been read |
| consumer : KafkaConsumer[Array[Byte], Array[Byte]] | The consumer to fetch messages |
| metric : mutable.Map[MetricName, _ <: Metric] | The metric for consumer, which used to get rebalanceTime |
Compatibility, Deprecation, and Migration Plan
...