lib/karafka/web/processing/consumers/aggregators/metrics.rb in karafka-web-0.7.10 vs lib/karafka/web/processing/consumers/aggregators/metrics.rb in karafka-web-0.8.0.rc1

- old
+ new

@@ -8,12 +8,11 @@ # Aggregates metrics for metrics topic. Tracks consumers data and converts it into a # state that can then be used to enrich previous time based states to get a time-series # values for charts and metrics class Metrics < Base # Current schema version - # This can be used in the future for detecting incompatible changes and writing - # migrations - SCHEMA_VERSION = '1.0.0' + # This is used for detecting incompatible changes and writing migrations + SCHEMA_VERSION = '1.1.2' def initialize super @aggregated_tracker = TimeSeriesTracker.new(metrics.fetch(:aggregated)) @consumer_groups_tracker = TimeSeriesTracker.new(metrics.fetch(:consumer_groups))