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-11-02 16:30:09 +08:00
parent 81a4862dc2
commit 2c488ee93b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/KafkaProviders.php
+4 -4
View File
@@ -26,14 +26,14 @@ class KafkaProviders extends Providers
{ {
/** @var Server $server */ /** @var Server $server */
$server = $application->get('server'); $server = $application->get('server');
$application->set('kafka', [ $application->set('kafka', ['class' => Producer::class]);
'class' => Producer::class
]);
$kafka = SConfig::get('kafka'); $kafka = SConfig::get('kafka');
if (empty($kafka) || !($kafka['enable'] ?? false)) { if (empty($kafka) || !($kafka['enable'] ?? false)) {
return; return;
} }
if (!extension_loaded('rdkafka')) {
return;
}
$server->addProcess('kafka', Kafka::class); $server->addProcess('kafka', Kafka::class);
} }