Code Review / nonrtric / plt / dmaapadapter.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 34380af) | patch
DMaaP adapter, support for shared Kafka topics 57/10057/3
authorPatrikBuhr <patrik.buhr@est.tech>
Thu, 8 Dec 2022 13:28:23 +0000 (14:28 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Mon, 12 Dec 2022 13:21:55 +0000 (14:21 +0100)
commit4c0683253887523af51193b8e421226e03c64309
tree3e5afffdb71cc10732ca8c13ac37e48318a27115tree | snapshot
parent34380afdabd939cb9ed13b600906e6a076016f50commit | diff
DMaaP adapter, support for shared Kafka topics

If several PM subscribers specify the same Kafka ouput topic, the
ouput objects will contain the sum of all filtered output data.

Added info type if to the kafka header

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-820
Change-Id: I33e6950f91fa0088658f463506a7c70670cc6e42
26 files changed:
docs/Pictures.pptx diff | blob | history
docs/dedicatedTopics.png [new file with mode: 0644] blob
docs/overview.rst diff | blob | history
docs/sharedTopics.png [new file with mode: 0644] blob
src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/Filter.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/FilterFactory.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/JsltFilter.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/JsonPathFilter.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/PmReport.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/PmReportFilter.java diff | blob | history
src/main/java/org/oran/dmaapadapter/filter/RegexpFilter.java diff | blob | history
src/main/java/org/oran/dmaapadapter/repository/Job.java diff | blob | history
src/main/java/org/oran/dmaapadapter/repository/Jobs.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicListener.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/HttpJobDataDistributor.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/JobDataDistributor.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataDistributor.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/TopicListener.java diff | blob | history
src/main/java/org/oran/dmaapadapter/tasks/TopicListeners.java diff | blob | history
src/test/java/org/oran/dmaapadapter/ConsumerController.java diff | blob | history
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java diff | blob | history
src/test/java/org/oran/dmaapadapter/filter/JsltFilterTest.java diff | blob | history
src/test/java/org/oran/dmaapadapter/filter/JsonPathFilterTest.java diff | blob | history
src/test/java/org/oran/dmaapadapter/filter/PmReportFilterTest.java diff | blob | history
"nonrtric_plt_dmaapadapter"