connect consumer to brokers

Superbalist · Dec 9, 2017 · f01e572 · f01e572
1 parent 9443db0
commit f01e572
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/PubSubConnectionFactory.php b/src/PubSubConnectionFactory.php
@@ -98,6 +98,7 @@ protected function makeKafkaAdapter(array $config)
         $conf->setDefaultTopicConf($topicConf);
 
         $consumer = $this->container->makeWith('pubsub.kafka.consumer', ['conf' => $conf]);
+        $consumer->addBrokers($config['brokers']);
 
         return new KafkaPubSubAdapter($producer, $consumer);
     }