diff --git a/Kafka/Producer.php b/Kafka/Producer.php
index b44d5da2..b9cd8229 100644
--- a/Kafka/Producer.php
+++ b/Kafka/Producer.php
@@ -109,22 +109,17 @@ class Producer extends Component
 		$rk->flush($timeout);
 
 		$event = Snowflake::app()->getEvent();
-		$event->on(Event::EVENT_AFTER_REQUEST, function ($rk, $timeout) {
-			var_dump(func_get_args());
-		}, [$rk, $timeout]);
+		$event->on(Event::EVENT_AFTER_REQUEST, [$this,'onFlush'], [$rk, $timeout]);
 	}
 
 
 	/**
-	 * @throws NotFindClassException
-	 * @throws ReflectionException
+	 * @param $rk
+	 * @param $timeout
 	 */
-	public function onFlush()
+	public function onFlush($rk, $timeout)
 	{
-		/** @var \RdKafka\Producer $rk */
-		$rk = Snowflake::getDi()->get(\RdKafka\Producer::class);
-
 		$this->debug(Event::EVENT_AFTER_REQUEST);
-		$rk->flush(10);
+		$rk->flush($timeout);
 	}
 }
diff --git a/System/Event.php b/System/Event.php
index d9e7d5d2..e049c8c9 100644
--- a/System/Event.php
+++ b/System/Event.php
@@ -14,9 +14,9 @@ use Snowflake\Core\ArrayAccess;
 class Event extends BaseObject
 {
 
-	public $isVide = true;
+	public bool $isVide = true;
 
-	private $_events = [];
+	private array $_events = [];
 
 	const EVENT_ERROR = 'WORKER:ERROR';
 	const EVENT_STOP = 'WORKER:STOP';
@@ -191,6 +191,7 @@ class Event extends BaseObject
 			return $result;
 		}
 		foreach ($this->_events[$name] as $event) {
+			var_dump($event);
 			[$handler, $defaultParameter] = $event;
 			try {
 				if (!empty($parameter)) {