改名

2021-08-05 15:26:58 +08:00
parent e71fc2e809
commit ad5d636937
1 changed files with 1 additions and 1 deletions
@@ -45,7 +45,7 @@ class KafkaClient
 	 */
 	private function setConfig(Conf $kafkaConfig)
 	{
-		$config = Config::get('producers.' . $this->topic, null, true);
+		$config = Config::get('kafka.producers.' . $this->topic, null, true);
 		if (!isset($config['brokers']) || !isset($config['groupId'])) {
 			throw new ConfigException('Please configure relevant information.');
 		}