Adding source name to kafka headers

[nonrtric/plt/ranpm.git] / pmproducer / src / main / java / org / oran / pmproducer / filter / PmReportFilter.java

diff --git a/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java b/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java
index 26bdf58..00f90f6 100644 (file)
--- a/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java
+++ b/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java
@@ -193,7 +193,8 @@ public class PmReportFilter {
             if (reportFiltered == null) {
                 return FilteredData.empty();
             }
-            return new FilteredData(data.infoTypeId, data.key, gson.toJson(reportFiltered).getBytes());
+            return new FilteredData(reportFiltered.event.getCommonEventHeader().getSourceName(), data.infoTypeId,
+                    data.key, gson.toJson(reportFiltered).getBytes());
         } catch (Exception e) {
             logger.warn("Could not parse PM data. {}, reason: {}", data, e.getMessage());
             return FilteredData.empty();