From 5c63a9a89495cbd0dc26115908736f35da762ed3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 24 Mar 2021 19:41:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/Producer.php | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/Kafka/Producer.php b/Kafka/Producer.php index 0697e7a2..36e9877d 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -108,10 +108,7 @@ class Producer extends Component } else if (!isset($consumers['groupId'])) { $consumers['groupId'] = $topic . ':' . Snowflake::localhost(); } - - var_dump(swoole_serialize($params)); - - $this->setGroupId($groupId)->setTopic($topic) + $this->setGroupId($consumers['groupId'])->setTopic($topic) ->setBrokers($consumers['brokers']) ->delivery(swoole_serialize($params)); }