改名

2020-10-28 11:42:31 +08:00
parent 8d72aa7e8b
commit 39ad35393f
1 changed files with 1 additions and 0 deletions
@@ -81,6 +81,7 @@ class Kafka extends \Snowflake\Process\Process
 						$this->application->debug('message null.');
 						continue;
 					}
+					var_dump($message);
 					switch ($message->err) {
 						case RD_KAFKA_RESP_ERR_NO_ERROR:
 							$this->channel->push([$message->topic_name, $message]);