connect consumer to brokers

evictor · evictor · commit f01e572a8a00 · 2017-12-08T17:08:39.000-08:00
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);
     }

Original file line number	Diff line number	Diff line change
`@@ -98,6 +98,7 @@ protected function makeKafkaAdapter(array $config)`
`98`	`98`	`$conf->setDefaultTopicConf($topicConf);`
`99`	`99`
`100`	`100`	`$consumer = $this->container->makeWith('pubsub.kafka.consumer', ['conf' => $conf]);`
	`101`	`+ $consumer->addBrokers($config['brokers']);`
`101`	`102`
`102`	`103`	`return new KafkaPubSubAdapter($producer, $consumer);`
`103`	`104`	`}`