Skip to content
This repository was archived by the owner on Oct 27, 2025. It is now read-only.

Commit 3b9bc3a

Browse files
committed
Tweak MockClusterTest::testSetBrokerDownAndUp
* ensure broker is down before requesting metadata
1 parent 52e7403 commit 3b9bc3a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

tests/RdKafka/Test/MockClusterTest.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -269,6 +269,8 @@ public function testSetBrokerDownAndUp(): void
269269
$producer = new Producer($producerConfig);
270270

271271
$cluster->setBrokerDown(1);
272+
sleep(1);
273+
272274
try {
273275
$producer->getMetadata(false, null, KAFKA_TEST_TIMEOUT_MS);
274276
$errorCode = 0;

0 commit comments

Comments
 (0)