Code Review
/
nonrtric
/
plt
/
ranpm.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
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();
}
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();
} catch (Exception e) {
logger.warn("Could not parse PM data. {}, reason: {}", data, e.getMessage());
return FilteredData.empty();