get_member_id leak fix

ilejn · ilejn · commit 52f912e450c4 · 2023-07-14T00:06:37.000+03:00
diff --git 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 {

Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,10 @@ TopicPartitionList Consumer::get_assignment() const {`
`240`	`240`	`}`
`241`	`241`
`242`	`242`	`string Consumer::get_member_id() const {`
`243`		`- return rd_kafka_memberid(get_handle());`
	`243`	`+ char* memberid_ptr = rd_kafka_memberid(get_handle());`
	`244`	`+ string memberid_string = memberid_ptr;`
	`245`	`+ rd_kafka_mem_free(nullptr, memberid_ptr);`
	`246`	`+ return memberid_string;`
`244`	`247`	`}`
`245`	`248`
`246`	`249`	`const Consumer::AssignmentCallback& Consumer::get_assignment_callback() const {`