diff --git a/Kafka/KafkaProviders.php b/Kafka/KafkaProviders.php
index 7042b8ab..912dd3e4 100644
--- a/Kafka/KafkaProviders.php
+++ b/Kafka/KafkaProviders.php
@@ -46,7 +46,7 @@ class KafkaProviders extends Providers
 		if (!is_array($kafka['topics'])) {
 			throw new Exception('Add kafka topics must is array.');
 		}
-		$server->addProcess('kafka', Kafka::class);
+		$server->addProcess('kafka', [Kafka::class, true]);
 	}
 
 }