From 24e0e9c6c329343a38da6eb999bd1e9f33f11732 Mon Sep 17 00:00:00 2001 From: Ivan Keberlein Date: Tue, 6 Jun 2023 16:16:55 +0300 Subject: [PATCH] Fix kafka consumer not destroyed in close --- kafka_consumer.c | 1 + 1 file changed, 1 insertion(+) diff --git a/kafka_consumer.c b/kafka_consumer.c index f00a20d5..2bf25a0a 100644 --- 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; } /* }}} */