Skip to content
This repository was archived by the owner on Jun 10, 2022. It is now read-only.

Commit aa93b5b

Browse files
committed
Revert "foolish check…."
This reverts commit 940bb23.
1 parent 940bb23 commit aa93b5b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

tests/Functional/ProducerTest.php

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,8 +143,9 @@ function () use (&$consumedMessages, $executionEnd): bool {
143143
);
144144

145145
$consumer->start(
146-
function (string $topic, int $partition, array $message) use ($assert): void {
146+
function (string $topic, int $partition, array $message) use (&$consumedMessages, $assert): void {
147147
if ($assert) {
148+
148149
self::assertSame($this->topic, $topic);
149150
self::assertLessThan(3, $partition);
150151
self::assertArrayHasKey('offset', $message);
@@ -156,13 +157,16 @@ function (string $topic, int $partition, array $message) use ($assert): void {
156157
self::assertArrayHasKey('key', $message['message']);
157158
self::assertArrayHasKey('value', $message['message']);
158159
self::assertContains('msg-', $message['message']['value']);
160+
159161
self::assertEquals(1, $message['offset']);
160162
} else {
161163

162164
throw new Exception();
163165
}
164166
}
165167
);
168+
169+
self::assertSame(self::MESSAGES_TO_SEND, $consumedMessages);
166170
}
167171

168172
private function configureConsumer(): void

0 commit comments

Comments
 (0)