Rui Li

## What is the purpose of the change Refactor KafkaOffsetMetric to use V2 metrics ## How was the change tested Ran `KafkaSpoutTopologyMainNamedTopics` with `org.apache.storm.metrics2.reporters.ConsoleStormReporter` ``` 2021-07-19 06:28:17.889 c.c.m.ConsoleReporter metrics-console-reporter-1-thread-1 [INFO]...

## What is the purpose of the change Adding submitLock to leaderCallBack to avoid race-condition. ## How was the change tested First, we reproduce the NPE exception by adding 60s...

[STORM-3565] add support for adding dimensions to metric data points

2

A dimensional metric collects information into multiple sub-categories (dimensions). Add an interface `IDimensionalMetric` extending `IMetric` in hope for supporting a better fine-grained metric reporting. `DimensionalCountMetric` serves as an example for...