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
 {