改名

2021-02-14 21:37:50 +08:00
parent 6cabb6cacd
commit 41d1e73d87
1 changed files with 1 additions and 1 deletions
@@ -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 Consumer ' . $kafkaServer['topic']);

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