Update Producer.php

usualtool · Apr 13, 2022 · 4081f06 · 4081f06
1 parent d9b53ce
commit 4081f06
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Producer.php b/src/Producer.php
@@ -9,8 +9,8 @@ public function Send($message){
         $conf = new \RdKafka\Conf();
         $conf->set("metadata.broker.list",$this->host);
         $producer = new \RdKafka\Producer($conf);
-        $topic = $producer->newTopic($this->topic);
-        $topic->produce(RD_KAFKA_PARTITION_UA,0,$message);
+        $topics = $producer->newTopic($this->topic);
+        $topics->produce(RD_KAFKA_PARTITION_UA,0,$message);
         $producer->poll(0);
     }
 }