Skip to content

Commit c7bffdb

Browse files
committed
Fix for test flakyness
1 parent 4f22357 commit c7bffdb

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

test/promisified/admin/fetch_offsets.spec.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -132,8 +132,7 @@ describe("fetchOffset function", () => {
132132
await consumer.run({
133133
eachMessage: async ({ topic, partition, message }) => {
134134

135-
messagesConsumed.push(message); // Populate messagesConsumed
136-
if (messagesConsumed.length === 5) {
135+
if (messagesConsumed.length === 4) {
137136
await consumer.commitOffsets([
138137
{
139138
topic,
@@ -142,6 +141,7 @@ describe("fetchOffset function", () => {
142141
},
143142
]);
144143
}
144+
messagesConsumed.push(message); // Populate messagesConsumed
145145
},
146146
});
147147

0 commit comments

Comments
 (0)