diff --git a/Kafka/Struct.php b/Kafka/Struct.php index 9dc755eb..1800646f 100644 --- a/Kafka/Struct.php +++ b/Kafka/Struct.php @@ -24,6 +24,7 @@ class Struct */ public function __construct($topic, Message $message) { + var_dump($message->payload); $message->payload = swoole_unserialize($message->payload); $this->topic = $topic;