From dfb31ee2a2f490cd5c2c05f7769aeae591c6098b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Wed, 28 Oct 2020 15:54:09 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Kafka/Kafka.php                      | 3 ++-
 System/Abstracts/BaseApplication.php | 2 ++
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index 652c7da3..ba1be7d5 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -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)
diff --git a/System/Abstracts/BaseApplication.php b/System/Abstracts/BaseApplication.php
index e0faa60a..d2261054 100644
--- a/System/Abstracts/BaseApplication.php
+++ b/System/Abstracts/BaseApplication.php
@@ -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
 {