NONRTRIC - Implement DMaaP mediator producer service in Java 90/7090/2
authorPatrikBuhr <patrik.buhr@est.tech>
Fri, 19 Nov 2021 12:48:07 +0000 (13:48 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Mon, 22 Nov 2021 09:27:17 +0000 (10:27 +0100)
commit242299199382ec3fd7d514dde2eb607086a6a46e
tree921e1d19e071a2553fc08a55f3002bd7135c999c
parent0f6367023720ecc7d7b4b38cbbc4282792172a89
NONRTRIC - Implement DMaaP mediator producer service in Java

Added regexp filtering of dmaap messages.

Fixed problem in kafka listening.

Fixed problems in integration tests.

Added a test for creating a kafka job, just to improve coverage.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-597
Change-Id: Id969a94dbcd2f52d6c3487f03c7e22b9c6582580
16 files changed:
dmaap-adaptor-java/api/api.json
dmaap-adaptor-java/api/api.yaml
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/controllers/ProducerCallbacksController.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/MultiMap.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicConsumer.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataConsumer.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java
dmaap-adaptor-java/src/main/resources/typeSchemaKafka.json
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/ApplicationTest.java
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/IntegrationWithEcs.java
dmaap-adaptor-java/src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java
dmaap-adaptor-java/src/test/resources/test_application_configuration.json
dmaap-adaptor-java/src/test/resources/test_application_configuration_kafka.json [deleted file]