From 7fc50c37db724ed5a4f6d3c54d40461c4133b5e4 Mon Sep 17 00:00:00 2001 From: Slaven Rezic Date: Wed, 27 Mar 2019 11:46:07 +0100 Subject: [PATCH] fix memory leak Two rd_kafka_topic_partition_list_destroy calls were missing. --- Rdkafka.xs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/Rdkafka.xs b/Rdkafka.xs index 3b13406..474a408 100644 --- a/Rdkafka.xs +++ b/Rdkafka.xs @@ -122,6 +122,7 @@ krd_assign(rdk, tplistsv = NULL) tpar = krd_parse_topic_partition_list(aTHX_ tplist); } RETVAL = rd_kafka_assign(rdk->rk, tpar); + rd_kafka_topic_partition_list_destroy(tpar); OUTPUT: RETVAL @@ -160,6 +161,7 @@ krd_commit(rdk, tplistsv = NULL, async = 0) tpar = krd_parse_topic_partition_list(aTHX_ tplist); } RETVAL = rd_kafka_commit(rdk->rk, tpar, async); + rd_kafka_topic_partition_list_destroy(tpar); OUTPUT: RETVAL