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

Commit 940bb23

Browse files
committed
foolish check….
1 parent 33cc115 commit 940bb23

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

tests/Functional/ProducerTest.php

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

145145
$consumer->start(
146-
function (string $topic, int $partition, array $message) use (&$consumedMessages, $assert): void {
146+
function (string $topic, int $partition, array $message) use ($assert): void {
147147
if ($assert) {
148-
149148
self::assertSame($this->topic, $topic);
150149
self::assertLessThan(3, $partition);
151150
self::assertArrayHasKey('offset', $message);
@@ -157,16 +156,13 @@ function (string $topic, int $partition, array $message) use (&$consumedMessages
157156
self::assertArrayHasKey('key', $message['message']);
158157
self::assertArrayHasKey('value', $message['message']);
159158
self::assertContains('msg-', $message['message']['value']);
160-
161159
self::assertEquals(1, $message['offset']);
162160
} else {
163161

164162
throw new Exception();
165163
}
166164
}
167165
);
168-
169-
self::assertSame(self::MESSAGES_TO_SEND, $consumedMessages);
170166
}
171167

172168
private function configureConsumer(): void

0 commit comments

Comments
 (0)