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);