diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index a91a057d..6382899a 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -33,7 +33,7 @@ class Kafka extends \Snowflake\Process\Process
 	 */
 	public function onHandler(Process $process): void
 	{
-		$this->waite(json_decode($process->read(), true));
+		$this->waite(swoole_unserialize($process->read()));
 	}