改名

2020-10-27 18:46:45 +08:00
parent f3510c3b39
commit cdf44a3768
1 changed files with 1 additions and 1 deletions
@@ -151,7 +151,7 @@ class Kafka extends \Snowflake\Process\Process
 		$topicConf = new TopicConf();
 		$topicConf->set('auto.offset.reset', 'smallest');

-		$conf->setDefaultTopicConf($topicConf);
+//		$conf->setDefaultTopicConf($topicConf);

 		return [$conf, $kafka];
 	}