改名

2020-10-26 17:20:15 +08:00
parent 58f3a86ba4
commit 80d7974842
1 changed files with 1 additions and 0 deletions
@@ -112,6 +112,7 @@ class Kafka extends \Snowflake\Process\Process
 	protected function handlerExecute($topic, $part, $message)
 	{
 		try {
+			var_dump($message);
 			$namespace = 'App\\Kafka\\' . ucfirst($topic) . 'Consumer';
 			if (!class_exists($namespace)) {
 				return;