改名

Kafka/Kafka.php

@@ -62,10 +62,11 @@ class Kafka implements CustomProcess
     }
 
 
-    /**
-     * @param array $kafkaServer
-     * @throws \Exception
-     */
+	/**
+	 * @param Process $process
+	 * @param array $kafkaServer
+	 * @throws \Exception
+	 */
     private function waite(Process $process, array $kafkaServer)
     {
         try {

Kafka/Producer.php

@@ -42,7 +42,7 @@ class Producer extends Component
      * @param array $config
      * @throws Exception
      */
-    public function __construct($config = [])
+    public function __construct(array $config = [])
     {
         parent::__construct($config);
         if (!class_exists(Conf::class)) {
@@ -56,10 +56,10 @@ class Producer extends Component
     }
 
 
-    /**
-     * @param $servers
-     * @return Producer
-     */
+	/**
+	 * @param string $servers
+	 * @return Producer
+	 */
     public function setBrokers(string $servers): static
     {
         $this->conf->set('metadata.broker.list', $servers);