改名
This commit is contained in:
+2
-3
@@ -25,8 +25,7 @@ use function Amp\stop;
|
|||||||
class Kafka extends \Snowflake\Process\Process
|
class Kafka extends \Snowflake\Process\Process
|
||||||
{
|
{
|
||||||
|
|
||||||
/** @var Channel */
|
protected Channel $channel;
|
||||||
protected $channel;
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -80,7 +79,7 @@ class Kafka extends \Snowflake\Process\Process
|
|||||||
$message = $topic->consume(0, $conf['metadataRefreshIntervalMs'] ?? 1000);
|
$message = $topic->consume(0, $conf['metadataRefreshIntervalMs'] ?? 1000);
|
||||||
if (empty($message)) {
|
if (empty($message)) {
|
||||||
$this->application->debug('message null.');
|
$this->application->debug('message null.');
|
||||||
return;
|
continue;
|
||||||
}
|
}
|
||||||
switch ($message->err) {
|
switch ($message->err) {
|
||||||
case RD_KAFKA_RESP_ERR_NO_ERROR:
|
case RD_KAFKA_RESP_ERR_NO_ERROR:
|
||||||
|
|||||||
Reference in New Issue
Block a user