as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-08-19 18:56:38 +08:00
parent 2b4929fa97
commit 1b9647da65
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+1 -2
View File
@@ -74,7 +74,7 @@ class Kafka extends CustomProcess
$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED); $topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
do { do {
if ($this->isStop) { if ($this->checkProcessIsStop()) {
$this->exit(); $this->exit();
break; break;
} }
@@ -106,7 +106,6 @@ class Kafka extends CustomProcess
logger()->error($message->errstr()); logger()->error($message->errstr());
} }
} }
Coroutine::sleep(0.01);
} catch (Throwable $exception) { } catch (Throwable $exception) {
logger()->addError($exception, 'throwable'); logger()->addError($exception, 'throwable');
} }