改名

2020-10-09 17:58:28 +08:00
parent deaaf9ab86
commit b3b5d2f6e6
1 changed files with 1 additions and 0 deletions
@@ -36,6 +36,7 @@ class Kafka extends \Snowflake\Process\Process
 		$consumer->setLogger(new Logger());
 		$consumer->start(function ($topic, $part, $message) {
 			try {
+				var_dump($topic, $part, $message);
 				$namespace = 'App\\Kafka\\' . ucfirst($topic) . 'Consumer';
 				if (!class_exists($namespace)) {
 					return;