lib/karafka/web/processing/consumers/aggregators/metrics.rb in karafka-web-0.8.2 vs lib/karafka/web/processing/consumers/aggregators/metrics.rb in karafka-web-0.9.0.rc1

- old
+ new

@@ -68,10 +68,10 @@ # care about what a stopped process was doing and we can also remove it from active # reports. def evict_expired_processes max_ttl = @aggregated_from - ::Karafka::Web.config.ttl / 1_000 - @active_reports.delete_if do |_name, report| + @active_reports.delete_if do |_id, report| report[:dispatched_at] < max_ttl || report[:process][:status] == 'stopped' end end # Materialize and add consumers groups states into the tracker