diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index b84de28e..7bb7ba14 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -159,6 +159,7 @@ class Kafka extends \Snowflake\Process\Process
 		try {
 			$topicConf->set('auto.commit.enable', '1');
 			$topicConf->set('auto.commit.interval.ms', '100');
+			$topicConf->set('auto.create.topics.enable', 'true');
 
 			//smallest：简单理解为从头开始消费，
 			//largest：简单理解为从最新的开始消费