改名

2021-08-19 18:49:14 +08:00
parent 11568decb4
commit 2b4929fa97
1 changed files with 1 additions and 0 deletions
@@ -75,6 +75,7 @@ class Kafka extends CustomProcess
 			$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
 			do {
 				if ($this->isStop) {
+					$this->exit();
 					break;
 				}
 				$this->resolve($topic, $conf['interval'] ?? 1000);