From 1b9647da655b426d0b57b3ad4daab5aeb18b3732 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Thu, 19 Aug 2021 18:56:38 +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, 1 insertion(+), 2 deletions(-)

diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index 74b4d91e..938f56b5 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -74,7 +74,7 @@ class Kafka extends CustomProcess
 
 			$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
 			do {
-				if ($this->isStop) {
+				if ($this->checkProcessIsStop()) {
 					$this->exit();
 					break;
 				}
@@ -106,7 +106,6 @@ class Kafka extends CustomProcess
 					logger()->error($message->errstr());
 				}
 			}
-			Coroutine::sleep(0.01);
 		} catch (Throwable $exception) {
 			logger()->addError($exception, 'throwable');
 		}