Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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:

...