diff --git a/Kafka/Producer.php b/Kafka/Producer.php index 34ee0797..efb463aa 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -105,6 +105,7 @@ class Producer extends Component } else if (!isset($consumers['groupId'])) { $consumers['groupId'] = $topic . ':' . Snowflake::localhost(); } + var_dump($consumers['groupId'], $consumers['brokers'], $topic); $this->setGroupId($consumers['groupId'])->setTopic($topic) ->setBrokers($consumers['brokers']) ->delivery(swoole_serialize($params));