改名

2020-10-27 18:46:22 +08:00
parent 5791a90b5c
commit f3510c3b39
1 changed files with 6 additions and 0 deletions
@@ -6,6 +6,7 @@ namespace Kafka;

 use RdKafka\Conf;
 use RdKafka\KafkaConsumer;
+use RdKafka\TopicConf;
 use Snowflake\Exception\ConfigException;
 use Snowflake\Snowflake;
 use Swoole\Coroutine;
@@ -147,6 +148,11 @@ class Kafka extends \Snowflake\Process\Process

 		$conf->set('metadata.broker.list', '127.0.0.1:9092');

+		$topicConf = new TopicConf();
+		$topicConf->set('auto.offset.reset', 'smallest');
+
+		$conf->setDefaultTopicConf($topicConf);
+
 		return [$conf, $kafka];
 	}