This commit is contained in:
2021-02-14 21:36:58 +08:00
parent b9c9e8216a
commit 6cabb6cacd
+1 -1
View File
@@ -53,7 +53,7 @@ class Kafka extends \Snowflake\Process\Process
{
try {
$prefix = ucfirst(rtrim(Snowflake::app()->id, ':'));
swoole_set_process_name($prefix . ' Kafka_' . $kafkaServer['topic']);
swoole_set_process_name($prefix . ': Kafka_' . $kafkaServer['topic']);
[$config, $topic, $conf] = $this->kafkaConfig($kafkaServer);
if (empty($config) && empty($topic) && empty($conf)) {