Fix broken RDKafka Implementation

pboethig · pboethig · commit 7b5ae5f875d2 · 2020-12-03T14:46:50.000+01:00
diff --git a/src/Queue/KafkaQueue.php b/src/Queue/KafkaQueue.php
@@ -153,7 +153,7 @@ public function pop($queue = null)
             }
 
 
-            $message = $this->queues[$queue]->consume(0, 1000);
+            $message = $this->queues[$queue]->consume(1000);
 
             if ($message === null) {
                 return null;

Original file line number	Diff line number	Diff line change
`@@ -153,7 +153,7 @@ public function pop($queue = null)`
`153`	`153`	`}`
`154`	`154`
`155`	`155`
`156`		`- $message = $this->queues[$queue]->consume(0, 1000);`
	`156`	`+ $message = $this->queues[$queue]->consume(1000);`
`157`	`157`
`158`	`158`	`if ($message === null) {`
`159`	`159`	`return null;`