From 7fc50c37db724ed5a4f6d3c54d40461c4133b5e4 Mon Sep 17 00:00:00 2001
From: Slaven Rezic <slaven.rezic@idealo.de>
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