From 665dff9192b71f6f810eefc93b4beb9ff6f36a27 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Mon, 26 Oct 2020 16:52:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/Kafka.php | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index a82d747e..d886ef37 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -164,14 +164,14 @@ class Kafka extends \Snowflake\Process\Process } else { $conf->set('queue.buffering.max.ms', 1); } +// +// $topicConf = new \RdKafka\TopicConf(); +// $topicConf->set('auto.commit.enable', 1); +// $topicConf->set('auto.commit.interval.ms', 100); +// $topicConf->set('auto.offset.reset', 'smallest'); +// $topicConf->set('offset.store.path', 'kafka_offset.log'); - $topicConf = new \RdKafka\TopicConf(); - $topicConf->set('auto.commit.enable', 1); - $topicConf->set('auto.commit.interval.ms', 100); - $topicConf->set('auto.offset.reset', 'smallest'); - $topicConf->set('offset.store.path', 'kafka_offset.log'); - - $conf->setDefaultTopicConf($topicConf); +// $conf->set($topicConf); return [$conf, $kafka]; }