Code Review / nonrtric / plt / ranpm.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: d806dbe) | patch
Adding source name to kafka headers 58/10858/2
authorPatrikBuhr <patrik.buhr@est.tech>
Thu, 6 Apr 2023 11:03:35 +0000 (13:03 +0200)
committerPatrikBuhr <patrik.buhr@est.tech>
Thu, 6 Apr 2023 11:08:43 +0000 (13:08 +0200)
commitdb5cb9a3759fe227ce8654bd0be1c85080e83e3f
treefc5da87faa20b5c1d19ba2a84f449314b5e6f8c9tree | snapshot
parentd806dbef4f43bb9c631c818e96c1a39e440c5e6ccommit | diff
Adding source name to kafka headers

The name of the PM reporting node is added to the Kafka headers.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-859
Change-Id: I05bd520b953036fe347bed91a638a47228e896b4
pmproducer/src/main/java/org/oran/pmproducer/filter/FilteredData.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/repository/Job.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/tasks/JobDataDistributor.java diff | blob | history
pmproducer/src/main/java/org/oran/pmproducer/tasks/TopicListener.java diff | blob | history
pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithKafka.java diff | blob | history
"nonrtric_plt_ranpm"