改名

Kafka/Producer.php

@@ -115,10 +115,12 @@ class Producer extends Component
     }
 
 
-    /**
+	/**
-     * @return \RdKafka\Producer
+	 * @param \RdKafka\Producer $producer
-     * @throws Exception
+	 * @param $topic
-     */
+	 * @return ProducerTopic
+	 * @throws Exception
+	 */
     private function getProducerTopic(\RdKafka\Producer $producer, $topic): ProducerTopic
     {
         $pool = Snowflake::app()->getChannel();