Fix kafka consumer not destroyed in close

arnaud-lb · Jan 12, 2024 · 24e0e9c · 24e0e9c
1 parent 0aee7cf
commit 24e0e9c
Showing 1 changed file with 1 addition and 0 deletions.
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;
 }
 /* }}} */