Fix consumer test

tulios · May 2, 2022 · 5283c32 · 5283c32
1 parent fec70a8
commit 5283c32
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/consumer/__tests__/consumeMessages.spec.js b/src/consumer/__tests__/consumeMessages.spec.js
@@ -415,7 +415,7 @@ describe('Consumer', () => {
     expect(messagesConsumed.map(m => m.message.offset)).toEqual(messages.map((_, i) => `${i}`))
     const response = await admin.fetchOffsets({ groupId, topics: [topicName] })
     const { partitions } = response.find(({ topic }) => topic === topicName)
-    const partition = partitions.find(({ partition }) => partition === '0')
+    const partition = partitions.find(({ partition }) => partition === 0)
     expect(partition.offset).toEqual('100') // check if offsets were committed
   })