Code Review / nonrtric.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 6f48adb) | patch
NONRTRIC - Implement DMaaP mediator producer service in Java 72/7072/11
authorPatrikBuhr <patrik.buhr@est.tech>
Tue, 16 Nov 2021 09:58:25 +0000 (10:58 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Wed, 17 Nov 2021 09:07:13 +0000 (10:07 +0100)
commitce1d9f2d3e1d2713289dc4d2b5c246f99ec65160
tree522b901ef77850ee0bce9785ac30b33dc735b32ctree | snapshot
parent6f48adb69090799c74c29204dd2cd1737cc9d6accommit | diff
NONRTRIC - Implement DMaaP mediator producer service in Java

Improved resilence from Kafka errors. After an overflow, the stream will be restarted (currently after max 3 minutes).

In Kafka messages: if buffered, received message will be quoted.
When delivered to consumer, the REST content type will be JSON if buffered. If not buffered, no content type is sent.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-597
Change-Id: Id0fb2b572a491d32300b1d11a7794a97371ac074
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumer.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataConsumer.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java diff | blob | history
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ApplicationTest.java diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/EcsSimulatorController.java diff | blob | history
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java diff | blob | history
Parent repository for the O-RAN SC Non Real-Time RIC (NONRTRIC) project.