lib/karafka/web/tracking/consumers/sampler.rb in karafka-web-0.8.2 vs lib/karafka/web/tracking/consumers/sampler.rb in karafka-web-0.9.0.rc1
- old
+ new
@@ -13,11 +13,11 @@
:pauses, :jobs, :windows
# Current schema version
# This is used for detecting incompatible changes and not using outdated data during
# upgrades
- SCHEMA_VERSION = '1.2.9'
+ SCHEMA_VERSION = '1.3.0'
# Counters that count events occurrences during the given window
COUNTERS_BASE = {
# Number of processed batches
batches: 0,
@@ -68,11 +68,11 @@
schema_version: SCHEMA_VERSION,
type: 'consumer',
dispatched_at: float_now,
process: {
+ id: process_id,
started_at: started_at,
- name: process_name,
status: ::Karafka::App.config.internal.status.to_s,
listeners: listeners,
workers: workers,
memory_usage: @memory_usage,
memory_total_usage: @memory_total_usage,