[FIX] track memory leak

DIFRIN · DIFRIN · commit 1f1ea15c61d1 · 2024-03-28T07:14:17.000+01:00
Signed-off-by: difrin &lt;frindi.abderrahmane.ied@gmail.com&gt;
diff --git a/plugins/out_kafka/kafka.c b/plugins/out_kafka/kafka.c
@@ -230,13 +230,15 @@ int produce_message(struct flb_time *tm, msgpack_object *map,
                         flb_warn("Field '%s' not found or not a string value", field_name);
                         }
 
-                    flb_free(field_name); // Free allocated memory
-                    } 
+                    
+                } 
                 else {
                     /* Static header value */
                     rd_kafka_header_add(kafka_headers, hkey->str, flb_sds_len(hkey->str),
                                 hval->str, flb_sds_len(hval->str));
-                }  
+                }
+
+                flb_free(field_name); // Free allocated memory  
             }
         } 
         else {

Original file line number	Diff line number	Diff line change
`@@ -230,13 +230,15 @@ int produce_message(struct flb_time tm, msgpack_object map,`
`230`	`230`	`flb_warn("Field '%s' not found or not a string value", field_name);`
`231`	`231`	`}`
`232`	`232`
`233`		`- flb_free(field_name); // Free allocated memory`
`234`		`- }`
	`233`	`+`
	`234`	`+ }`
`235`	`235`	`else {`
`236`	`236`	`/* Static header value */`
`237`	`237`	`rd_kafka_header_add(kafka_headers, hkey->str, flb_sds_len(hkey->str),`
`238`	`238`	`hval->str, flb_sds_len(hval->str));`
`239`		`- }`
	`239`	`+ }`
	`240`	`+`
	`241`	`+ flb_free(field_name); // Free allocated memory`
`240`	`242`	`}`
`241`	`243`	`}`
`242`	`244`	`else {`