改名

2020-10-26 17:03:09 +08:00
parent 08cc691aff
commit f73afb6209
1 changed files with 1 additions and 1 deletions
@@ -35,7 +35,7 @@ class Kafka extends \Snowflake\Process\Process
 		$this->channelListener();
 		[$config, $conf] = $this->kafkaConfig();
 		$consumer = new \RdKafka\Consumer($config);
-		$consumer->addBrokers($config['brokers']);
+		$consumer->addBrokers($conf['brokers']);

 		$topic = $consumer->newTopic("test");
 		while (true) {