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))