...

• (deprecated) org.apache.kafka.common.metrics.stats.Count
• (new) org.apache.kafka.common.metrics.stats.SampledCountWindowedCount

sampled sum metric:

• (deprecated) org.apache.kafka.common.metrics.stats.Rate.SampledTotal
• (deprecated) org.apache.kafka.common.metrics.stats.Sum
• (new) org.apache.kafka.common.metrics.stats.SampledSumWindowedSum

non-sampled count metric:

• (internal: removed) org.apache.kafka.streams.processor.internals.metrics.CumulativeCount
• (new) org.apache.kafka.common.metrics.stats.TotalCountCumulativeCount

non-sampled sum metric:

• (deprecated) org.apache.kafka.common.metrics.stats.Total
• (new) org.apache.kafka.common.metrics.stats.TotalSumCumulativeSum

Proposed Changes

The existing metrics cover four quadrants of a matrix:

...

The proposal is simple:

Under this proposal, the metrics are clearly and regularly named and all quadrants are covered uniquely. There is no ambiguity in the names, and the structure of the names also indicate a pattern that would guide users to select the correct metric for their needs.

...

Existing metrics are deprecated in favor of unambiguously named ones. They will be made to subclass the new metrics to avoid code duplication, but this won't cause any code compatibility issues, since they'll still inherit the same interfaces.

Rejected Alternatives

...

• "Running" or "Total" instead of "Cumulative": After some discussion and some research, "Cumulative" appears to be the technically correct term: "In a cumulative moving average, the data arrive in an ordered datum stream, and the user would like to get the average of all of the data up until the current datum point." (https://en.wikipedia.org/wiki/Moving_average)
• "Sampled" instead of "Windowed": Sampling is the implementation, and in the current Metrics framework, it implies that the metric is windowed, but the name bears no such connotation. Since the distinction we wish to draw is the these metrics drop old data, as opposed to the cumulative ones, we choose a name that actually means it will drop old data.
• "Moving" instead of "Windowed": Any stat that is continuously updated is moving, whether it is windowed or not.
• "Simple" or "SimpleWindowed" instead of "Windowed": These options have the benefit that they specify the weighting function (uniform) in addition to implying windowing, but the term "simple" is itself jargon. It's also not necessary, as the absence of a weighting function in the name can also imply that the weighting is uniform. If we want to add a metric with some other function in the future, we can always name it like ExponentiallyWeightedWindowedBlahBlahBlah to differentiate it from WindowedBlahBlahBlah.