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
2020-10-12 11:51:49 +08:00
parent ff7e9c6ac8
commit 3ff6ac1f5b
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+4 -1
View File
@@ -51,7 +51,10 @@ class Kafka extends \Snowflake\Process\Process
$this->channelListener(); $this->channelListener();
$consumer = new Consumer(); $consumer = new Consumer();
$consumer->setLogger(new Logger()); $kafka = SConfig::get('kafka');
if ($kafka['debug'] ?? true) {
$consumer->setLogger(new Logger());
}
$consumer->start(function ($topic, $part, $message) { $consumer->start(function ($topic, $part, $message) {
$this->channel->push([$topic, $part, $message]); $this->channel->push([$topic, $part, $message]);
}); });