Code Review / nonrtric.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 6e323a6) | patch
NONRTRIC - Implement DMaaP mediator producer service in Java 33/7033/2
authorPatrikBuhr <patrik.buhr@est.tech>
Fri, 5 Nov 2021 13:56:19 +0000 (14:56 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Wed, 10 Nov 2021 12:59:39 +0000 (13:59 +0100)
commitb2d6339441c650962e34502e7527ca0835fa342f
treeadb0f941aff0478035b5d40ab46516ea157ded49tree | snapshot
parent6e323a6d8f04cec11b5f3f1a7fcb7c5f6b10247dcommit | diff
NONRTRIC - Implement DMaaP mediator producer service in Java

Fixed so that an information type can receive data from a Kafka stream.
This can also filter the data (using regexp matchning).
The received data can be buffered to minimize the number of REST calls to deliver the data to the consumer.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-597
Change-Id: Ie3740898bd919908a7ec5753f7d6050c652cebe4
20 files changed:
dmaap-adaptor-java/README.md diff | blob | history
dmaap-adaptor-java/config/application.yaml diff | blob | history
dmaap-adaptor-java/pom.xml diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/BeanFactory.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/configuration/ApplicationConfig.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/InfoType.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/InfoTypes.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Job.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Jobs.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumer.java [moved from dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/DmaapMessageConsumer.java with 85% similarity] diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumer.java [new file with mode: 0644] blob
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java [new file with mode: 0644] blob
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java diff | blob | history
dmaap-adaptor-java/src/main/resources/typeSchemaKafka.json [new file with mode: 0644] blob
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/EcsSimulatorController.java diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/IntegrationWithEcs.java diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java [new file with mode: 0644] blob
dmaap-adaptor-java/src/test/resources/test_application_configuration.json diff | blob | history
dmaap-adaptor-java/src/test/resources/test_application_configuration_kafka.json [new file with mode: 0644] blob
Parent repository for the O-RAN SC Non Real-Time RIC (NONRTRIC) project.