THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| 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 |
| testStartTime: Long | The time when the test starts |
Below are the flowcharts of ConsumerPerformance and ConsumerPerfThread. The general process is:
...