改名

2021-08-05 15:34:53 +08:00
parent 277e3cc13e
commit a9e172b975
1 changed files with 7 additions and 4 deletions
@@ -41,6 +41,7 @@ class Kafka implements CustomProcess


 	/**
+	 * @param Process $process
 	 * @return string
 	 * @throws ConfigException
 	 */
@@ -123,6 +124,8 @@ class Kafka implements CustomProcess
    {
        go(function () use ($topic, $message) {
            try {
+            	var_dump($topic, $message);
+
                $server = Snowflake::app()->getSwoole();

                $setting = $server->setting['worker_num'];