diff --git a/spec/lib/karafka/web/tracking/consumers/contracts/consumer_group_spec.rb b/spec/lib/karafka/web/tracking/consumers/contracts/consumer_group_spec.rb index f01b7fbe..722f11cc 100644 --- a/spec/lib/karafka/web/tracking/consumers/contracts/consumer_group_spec.rb +++ b/spec/lib/karafka/web/tracking/consumers/contracts/consumer_group_spec.rb @@ -31,7 +31,12 @@ poll_state: 'active', hi_offset: 10, lag_d: 10, - lag: 10 + lag: 10, + lo_offset: 0, + eof_offset: 0, + ls_offset: 0, + ls_offset_d: 0, + ls_offset_fd: 0 } } } diff --git a/spec/lib/karafka/web/tracking/consumers/contracts/report_spec.rb b/spec/lib/karafka/web/tracking/consumers/contracts/report_spec.rb index 9037bc6d..05ac2826 100644 --- a/spec/lib/karafka/web/tracking/consumers/contracts/report_spec.rb +++ b/spec/lib/karafka/web/tracking/consumers/contracts/report_spec.rb @@ -72,12 +72,17 @@ lag_stored_d: 0, lag: 0, lag_d: 0, - hi_offset: 0, committed_offset: 18, stored_offset: 18, fetch_state: 'active', id: 0, - poll_state: 'active' + poll_state: 'active', + hi_offset: 1, + lo_offset: 0, + eof_offset: 0, + ls_offset: 0, + ls_offset_d: 0, + ls_offset_fd: 0 } } } diff --git a/spec/lib/karafka/web/tracking/consumers/contracts/subscription_group_spec.rb b/spec/lib/karafka/web/tracking/consumers/contracts/subscription_group_spec.rb index 25f6190c..0e0e74bf 100644 --- a/spec/lib/karafka/web/tracking/consumers/contracts/subscription_group_spec.rb +++ b/spec/lib/karafka/web/tracking/consumers/contracts/subscription_group_spec.rb @@ -18,7 +18,12 @@ lag_d: 0, committed_offset: 100, stored_offset: 95, - hi_offset: 2 + hi_offset: 2, + lo_offset: 0, + eof_offset: 0, + ls_offset: 0, + ls_offset_d: 0, + ls_offset_fd: 0 } } } diff --git a/spec/lib/karafka/web/tracking/consumers/contracts/topic_spec.rb b/spec/lib/karafka/web/tracking/consumers/contracts/topic_spec.rb index 9e4aea24..899c2065 100644 --- a/spec/lib/karafka/web/tracking/consumers/contracts/topic_spec.rb +++ b/spec/lib/karafka/web/tracking/consumers/contracts/topic_spec.rb @@ -15,7 +15,14 @@ lag_d: 1, committed_offset: 100, stored_offset: 95, - hi_offset: 10 + fetch_state: 'active', + poll_state: 'active', + hi_offset: 1, + lo_offset: 0, + eof_offset: 0, + ls_offset: 0, + ls_offset_d: 0, + ls_offset_fd: 0 } } } diff --git a/spec/lib/karafka/web/tracking/sampler_spec.rb b/spec/lib/karafka/web/tracking/sampler_spec.rb index f6ebd279..06b8d903 100644 --- a/spec/lib/karafka/web/tracking/sampler_spec.rb +++ b/spec/lib/karafka/web/tracking/sampler_spec.rb @@ -6,7 +6,7 @@ it { expect(sampler.ruby_version).to start_with('ruby ') } it { expect(sampler.karafka_version).to include('2.2.') } it { expect(sampler.karafka_web_version).to include('0.7.') } - it { expect(sampler.karafka_core_version).to include('2.1.') } + it { expect(sampler.karafka_core_version).to include('2.2.') } it { expect(sampler.rdkafka_version).to start_with('0.1') } it { expect(sampler.librdkafka_version).to start_with('2.2') } it { expect(sampler.waterdrop_version).to start_with('2.') }