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-02-14 21:36:22 +08:00
parent 643c787a4b
commit b9c9e8216a
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+3 -1
View File
@@ -52,7 +52,9 @@ class Kafka extends \Snowflake\Process\Process
private function waite(array $kafkaServer) private function waite(array $kafkaServer)
{ {
try { try {
swoole_set_process_name('Kafka_' . $kafkaServer['topic']); $prefix = ucfirst(rtrim(Snowflake::app()->id, ':'));
swoole_set_process_name($prefix . ' Kafka_' . $kafkaServer['topic']);
[$config, $topic, $conf] = $this->kafkaConfig($kafkaServer); [$config, $topic, $conf] = $this->kafkaConfig($kafkaServer);
if (empty($config) && empty($topic) && empty($conf)) { if (empty($config) && empty($topic) && empty($conf)) {
return; return;