fix consumer timing out whilst waiting for partition assignment

Author: matthewgoslett

src/KafkaPubSubAdapter.php

@@ -61,7 +61,7 @@ public function subscribe($channel, callable $handler)
         $isSubscriptionLoopActive = true;
 
         while ($isSubscriptionLoopActive) {
-            $message = $this->consumer->consume(300);
+            $message = $this->consumer->consume(120*1000);
 
             if ($message === null) {
                 continue;