From 9b27cc5a9f3f105d3a2e10922def82a21eb9dbc6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 23 Dec 2020 16:23:18 +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 | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 8a1b5e54..5c12e6b9 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -160,12 +160,16 @@ class Kafka extends \Snowflake\Process\Process } $topicConf = new TopicConf(); - $topicConf->set('auto.commit.enable', '1'); - $topicConf->set('allow.auto.create.topics', 'true'); - $topicConf->set('auto.commit.interval.ms', '100'); - //smallest：简单理解为从头开始消费，largest：简单理解为从最新的开始消费 - $topicConf->set('auto.offset.reset', 'smallest'); - $topicConf->set('offset.store.path', 'kafka_offset.log'); + try { + $topicConf->set('auto.commit.enable', '1'); + $topicConf->set('auto.commit.interval.ms', '100'); + //smallest：简单理解为从头开始消费，largest：简单理解为从最新的开始消费 + $topicConf->set('auto.offset.reset', 'smallest'); + $topicConf->set('offset.store.path', 'kafka_offset.log'); + $topicConf->set('allow.auto.create.topics', 'true'); + } catch (Throwable $exception) { + var_dump($exception->getMessage()); + } return [$conf, $topicConf, $kafka]; }