clean rdKafkaConsumers list when context is close

dirk39 · leadspark · commit 130e934d98ca · 2019-09-12T09:31:03.000+02:00
diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
@@ -133,6 +133,7 @@ public function close(): void
     {
         $kafkaConsumers = $this->kafkaConsumers;
         $this->kafkaConsumers = [];
+        $this->rdKafkaConsumers = [];
 
         foreach ($kafkaConsumers as $kafkaConsumer) {
             $kafkaConsumer->unsubscribe();

Original file line number	Diff line number	Diff line change
`@@ -133,6 +133,7 @@ public function close(): void`
`133`	`133`	`{`
`134`	`134`	`$kafkaConsumers = $this->kafkaConsumers;`
`135`	`135`	`$this->kafkaConsumers = [];`
	`136`	`+ $this->rdKafkaConsumers = [];`
`136`	`137`
`137`	`138`	`foreach ($kafkaConsumers as $kafkaConsumer) {`
`138`	`139`	`$kafkaConsumer->unsubscribe();`