This commit is contained in:
2020-10-27 19:37:26 +08:00
parent 96944c44be
commit 0ea78d03a8
+1 -1
View File
@@ -145,7 +145,7 @@ class Kafka extends \Snowflake\Process\Process
} }
}); });
$conf->set('group.id', uniqid('kafka')); $conf->set('group.id', uniqid('kafka'));
$conf->set('metadata.broker.list', '127.0.0.1:9092'); $conf->set('metadata.broker.list', '127.0.0.1:2080');
$topicConf = new TopicConf(); $topicConf = new TopicConf();
$topicConf->set('auto.commit.enable', 1); $topicConf->set('auto.commit.enable', 1);