From 3eafeb52edb589ad91f827c5534f800174fcd66c Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Fri, 26 Mar 2021 01:18:11 +0800
Subject: [PATCH] modify

---
 Kafka/Kafka.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()));
 	}