fix SeekOffsets data structure

tulios · May 30, 2022 · 80e50fb · 80e50fb
1 parent 4ac6773
commit 80e50fb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/consumer/seekOffsets.js b/src/consumer/seekOffsets.js
@@ -1,6 +1,6 @@
 module.exports = class SeekOffsets extends Map {
   getKey(topic, partition) {
-    return JSON.stringify(topic, partition)
+    return JSON.stringify([topic, partition])
   }
 
   set(topic, partition, offset) {
@@ -14,7 +14,7 @@ module.exports = class SeekOffsets extends Map {
   }
 
   pop(topic, partition) {
-    if (this.size === 0) {
+    if (this.size === 0 || !this.has(topic, partition)) {
       return
     }