THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Also, add per partition lead metrics to KafkaConsumer. The metric names would be:
"TOPIC-PARTITION_ID.recordrecords-lead"
"TOPIC-PARTITION_ID.recordrecords-lead-avg"
"TOPIC-PARTITION_ID.recordrecords-lead-min"
The way to get the metrics is the same as getting other metrics. For example:
...