as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-12-23 16:18:40 +08:00
parent 22b2968658
commit cc9046d670
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+1 -1
View File
@@ -161,7 +161,7 @@ class Kafka extends \Snowflake\Process\Process
$topicConf = new TopicConf(); $topicConf = new TopicConf();
$topicConf->set('auto.commit.enable', '1'); $topicConf->set('auto.commit.enable', '1');
$topicConf->set('auto.create.topics.enable', 'true'); $topicConf->set('auto.create.topics.enable', '1');
$topicConf->set('auto.commit.interval.ms', '100'); $topicConf->set('auto.commit.interval.ms', '100');
//smallest：简单理解为从头开始消费，largest：简单理解为从最新的开始消费 //smallest：简单理解为从头开始消费，largest：简单理解为从最新的开始消费
$topicConf->set('auto.offset.reset', 'smallest'); $topicConf->set('auto.offset.reset', 'smallest');