Fix kafka consumer not destroyed in close

Ivan Keberlein · Ivan Keberlein · commit 24e0e9c6c329 · 2024-01-12T12:26:59.000+03:00
diff --git a/kafka_consumer.c b/kafka_consumer.c
@@ -485,6 +485,7 @@ PHP_METHOD(RdKafka_KafkaConsumer, close)
     }
 
     rd_kafka_consumer_close(intern->rk);
+    rd_kafka_destroy(intern->rk);
     intern->rk = NULL;
 }
 /* }}} */

Original file line number	Diff line number	Diff line change
`@@ -485,6 +485,7 @@ PHP_METHOD(RdKafka_KafkaConsumer, close)`
`485`	`485`	`}`
`486`	`486`
`487`	`487`	`rd_kafka_consumer_close(intern->rk);`
	`488`	`+ rd_kafka_destroy(intern->rk);`
`488`	`489`	`intern->rk = NULL;`
`489`	`490`	`}`
`490`	`491`	`/* }}} */`