fix typo

karafka · Aug 27, 2024 · b4432aa · b4432aa
1 parent bba853c
commit b4432aa
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,7 @@
 
 ## 0.10.2 (Unreleased)
 - [Fix] Prevent live-polling on elements wrapped in a button.
+- [Fix] Fix errors extractor failure on first message-less tick / eofed
 
 ## 0.10.1 (2024-08-23)
 - **[Feature]** Support Recurring Tasks management (Pro).

diff --git a/lib/karafka/web/tracking/consumers/listeners/errors.rb b/lib/karafka/web/tracking/consumers/listeners/errors.rb
@@ -73,7 +73,9 @@ def extract_consumer_info(consumer)
                 partition: consumer.partition,
                 first_offset: consumer.messages.metadata.first_offset,
                 last_offset: consumer.messages.metadata.last_offset,
-                committed_offset: consumer.coordinator.seek_offset - 1,
+                # We set it to -1000 if non-existent because after subtracting one, we will end up
+                # with -1001, which is "N/A" offset position for all the offsets here
+                committed_offset: (consumer.coordinator.seek_offset || -1_000) - 1,
                 consumer: consumer.class.to_s,
                 tags: consumer.tags
               }