Skip to content

Commit a0de66b

Browse files
committed
fix unit test
1 parent 2e39c5e commit a0de66b

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

tests/producer.test.js

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,6 @@ const adminUrl = 'http://localhost:8080';
225225
console.log(`Successfully received and verified ${receivedMessages.size} messages from ${expectedPartitionName}.`);
226226
await producer.close();
227227
await consumer.close();
228-
await client.close();
229228
}, 30000);
230229

231230
test('Custom Message Router Exception', async () => {
@@ -248,7 +247,6 @@ const adminUrl = 'http://localhost:8080';
248247
).rejects.toThrow('Custom router error');
249248

250249
await producer.close();
251-
await client.close();
252250
}, 30000);
253251
});
254252
});

0 commit comments

Comments
 (0)