改名

2020-12-28 18:02:15 +08:00
parent a95ebb610b
commit 7073096db5
1 changed files with 0 additions and 3 deletions
@@ -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);