From 7073096db57b13f7f615aaa630165c0b202b24d8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Mon, 28 Dec 2020 18:02:15 +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 | 3 --- 1 file changed, 3 deletions(-) diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 8ee7dd0c..612a4b19 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -49,7 +49,6 @@ class Kafka extends \Snowflake\Process\Process }); $this->waite($kafkaServer); }); - var_dump($kafkaServer); } $waite->wait(); } @@ -65,8 +64,6 @@ class Kafka extends \Snowflake\Process\Process $objRdKafka = new Consumer($config); $topic = $objRdKafka->newTopic($kafkaServer['topic'], $topic); - var_dump($kafkaServer['topic']); - $topic->consumeStart(0, RD_KAFKA_OFFSET_STORED); while (true) { $this->resolve($topic, $conf['interval'] ?? 1000);