diff --git a/Kafka/KafkaProviders.php b/Kafka/KafkaProviders.php index 912dd3e4..8f9cf817 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, true]); + $server->addProcess('kafka', [Kafka::class, false]); } }