specs

karafka · Sep 10, 2023 · c4a5e5d · c4a5e5d
1 parent 786c96a
commit c4a5e5d
Show file tree

Hide file tree

Showing 5 changed files with 28 additions and 6 deletions.
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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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.') }