改名

2021-03-03 19:04:14 +08:00
parent 1daf9d95ca
commit 3a496926c9
2 changed files with 7 additions and 1 deletions
@@ -52,7 +52,10 @@ class Kafka extends \Snowflake\Process\Process
 	{
 		try {
 			$prefix = rtrim(Snowflake::app()->id, ':');
-			swoole_set_process_name($prefix . ' Kafka Consumer ' . $kafkaServer['topic']);
+
+			if (!Snowflake::isMac()) {
+				swoole_set_process_name($prefix . ' Kafka Consumer ' . $kafkaServer['topic']);
+			}

 			[$config, $topic, $conf] = $this->kafkaConfig($kafkaServer);
 			if (empty($config) && empty($topic) && empty($conf)) {