diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index 4cff90ac..74b4d91e 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -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);