Skip to content

Commit 389e549

Browse files
authored
Merge pull request #33 from pboethig/next
Fix broken RDKafka Implementation on Laravel 8.1.x
2 parents 0435241 + 7b5ae5f commit 389e549

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Queue/KafkaQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ public function pop($queue = null)
153153
}
154154

155155

156-
$message = $this->queues[$queue]->consume(0, 1000);
156+
$message = $this->queues[$queue]->consume(1000);
157157

158158
if ($message === null) {
159159
return null;

0 commit comments

Comments
 (0)