Test that consumer can seek back to an already resolved offset

tulios · Jan 29, 2021 · 18c78d1 · 18c78d1
1 parent 9514382
commit 18c78d1
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/src/consumer/__tests__/seek.spec.js b/src/consumer/__tests__/seek.spec.js
@@ -186,7 +186,7 @@ describe('Consumer', () => {
         })
         await consumer.subscribe({ topic: topicName, fromBeginning: true })
 
-        const messagesConsumed = []
+        let messagesConsumed = []
         consumer.run({
           autoCommit: false,
           eachMessage: async event => messagesConsumed.push(event),
@@ -208,6 +208,22 @@ describe('Consumer', () => {
             offset: '-1',
           }),
         ])
+
+        messagesConsumed = []
+        consumer.seek({ topic: topicName, partition: 0, offset: 1 })
+
+        await expect(waitForMessages(messagesConsumed, { number: 2 })).resolves.toEqual([
+          {
+            topic: topicName,
+            partition: 0,
+            message: expect.objectContaining({ offset: '1' }),
+          },
+          {
+            topic: topicName,
+            partition: 0,
+            message: expect.objectContaining({ offset: '2' }),
+          },
+        ])
       })
     })
   })