From ff131c10adf9439ca0756c0efe6901fa6d677281 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sun, 4 Apr 2021 17:53:38 +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 7e6d7396..6640e11f 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -123,7 +123,7 @@ class Producer extends Component { $pool = Snowflake::app()->getChannel(); return $pool->pop($topic . '::' . ProducerTopic::class, function () use ($producer, $topic) { - return $producer->newTopic($topic, $this->topic_conf); + return $producer->newTopic($topic, $this->topicConf); }); }