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