From 52f912e450c429c31343a36b0eade389caae5f45 Mon Sep 17 00:00:00 2001 From: Ilya Golshtein Date: Fri, 14 Jul 2023 00:06:37 +0300 Subject: [PATCH] get_member_id leak fix --- src/consumer.cpp | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/consumer.cpp b/src/consumer.cpp index 38f156ad..a244c370 100644 --- a/src/consumer.cpp +++ b/src/consumer.cpp @@ -240,7 +240,10 @@ TopicPartitionList Consumer::get_assignment() const { } string Consumer::get_member_id() const { - return rd_kafka_memberid(get_handle()); + char* memberid_ptr = rd_kafka_memberid(get_handle()); + string memberid_string = memberid_ptr; + rd_kafka_mem_free(nullptr, memberid_ptr); + return memberid_string; } const Consumer::AssignmentCallback& Consumer::get_assignment_callback() const {