diff --git a/Kafka/Producer.php b/Kafka/Producer.php
index 7b636562..a3eebceb 100644
--- a/Kafka/Producer.php
+++ b/Kafka/Producer.php
@@ -115,10 +115,12 @@ class Producer extends Component
     }
 
 
-    /**
-     * @return \RdKafka\Producer
-     * @throws Exception
-     */
+	/**
+	 * @param \RdKafka\Producer $producer
+	 * @param $topic
+	 * @return ProducerTopic
+	 * @throws Exception
+	 */
     private function getProducerTopic(\RdKafka\Producer $producer, $topic): ProducerTopic
     {
         $pool = Snowflake::app()->getChannel();