改名

2021-02-14 21:33:49 +08:00
parent 68e0e82c71
commit 643c787a4b
1 changed files with 1 additions and 0 deletions
@@ -52,6 +52,7 @@ class Kafka extends \Snowflake\Process\Process
 	private function waite(array $kafkaServer)
 	{
 		try {
+			swoole_set_process_name('Kafka_' . $kafkaServer['topic']);
 			[$config, $topic, $conf] = $this->kafkaConfig($kafkaServer);
 			if (empty($config) && empty($topic) && empty($conf)) {
 				return;