diff --git a/src/Producer.php b/src/Producer.php index 7dda2d2..7669f8a 100644 --- 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); } }