From d63d937438654d7fff202f51b79d6bd31fa37a55 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sun, 4 Apr 2021 17:54:25 +0800 Subject: [PATCH] modify --- Kafka/Producer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Kafka/Producer.php b/Kafka/Producer.php index 6640e11f..7b636562 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -186,7 +186,7 @@ class Producer extends Component } foreach ($message as $value) { - $producerTopic->produce(RD_KAFKA_PARTITION_UA, 0, $value, $key); + $producerTopic->produce(RD_KAFKA_PARTITION_UA, 0, swoole_serialize($value), $key); $producer->poll(0); } $this->flush($producer);