initialized rdKafkaConsumers attribute

php-enqueue · Sep 12, 2019 · c4ba709 · c4ba709
1 parent 130e934
commit c4ba709
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
@@ -57,6 +57,7 @@ public function __construct(array $config)
     {
         $this->config = $config;
         $this->kafkaConsumers = [];
+        $this->rdKafkaConsumers = [];
 
         $this->setSerializer(new JsonSerializer());
     }