diff --git a/plugins/fluentd_telemetry_plugin/src/streamer.py b/plugins/fluentd_telemetry_plugin/src/streamer.py
index a1251d688..201f37c74 100644
--- a/plugins/fluentd_telemetry_plugin/src/streamer.py
+++ b/plugins/fluentd_telemetry_plugin/src/streamer.py
@@ -513,8 +513,8 @@ def _parse_telemetry_csv_metrics_to_json_without_delta(self, data):
                 key = modified_keys[i]
                 if value:
                     port_record[key] = self._convert_str_to_num(value)
-                    if is_meta_fields_available:
-                        port_record = self._append_meta_fields_to_dict(port_record)
+            if is_meta_fields_available:
+                port_record = self._append_meta_fields_to_dict(port_record)
             output.append(port_record)
         return output, None, keys_length