改名

2020-10-28 15:54:09 +08:00
parent ed7cbc0e71
commit dfb31ee2a2
2 changed files with 4 additions and 1 deletions
@@ -6,6 +6,7 @@ namespace Kafka;

 use RdKafka\Conf;
 use RdKafka\ConsumerTopic;
+use RdKafka\Exception;
 use RdKafka\KafkaConsumer;
 use RdKafka\TopicConf;
 use Snowflake\Exception\ConfigException;
@@ -193,7 +194,7 @@ class Kafka extends \Snowflake\Process\Process
 	 * @param KafkaConsumer $kafka
 	 * @param $err
 	 * @param array|null $partitions
-	 * @throws \RdKafka\Exception
+	 * @throws Exception
 	 * @throws \Exception
 	 */
 	public function rebalanced_cb(KafkaConsumer $kafka, $err, array $partitions = null)
@@ -16,6 +16,7 @@ use HttpServer\Http\Request;
 use HttpServer\Http\Response;
 use HttpServer\Route\Router;
 use HttpServer\Server;
+use Kafka\Producer;
 use Snowflake\Annotation\Annotation;
 use Snowflake\Cache\Memcached;
 use Snowflake\Cache\Redis;
@@ -49,6 +50,7 @@ use Database\DatabasesProviders;
 * @property Jwt $jwt
 * @property BaseGoto $goto
 * @property Client $client
+ * @property Producer $kafka
 */
 abstract class BaseApplication extends Service
 {