NONRTRIC - dmaap adapter characteristic improvement 32/8732/1
authorPatrikBuhr <patrik.buhr@est.tech>
Mon, 4 Jul 2022 13:28:05 +0000 (15:28 +0200)
committerPatrikBuhr <patrik.buhr@est.tech>
Tue, 5 Jul 2022 09:36:18 +0000 (11:36 +0200)
commit3e1de2de454e01cfa3fbacfc118506385aacce82
tree1dc0f26bb8d3904fc78a9bab1d9f3603a4f42d8c
parent03a3322bb69236892b4be69d018ab8428f584828
NONRTRIC - dmaap adapter characteristic improvement

Fixed issues with backpressure.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-773
Change-Id: I5d9a1cb7c741110010e3dd116a5c115061fb59dd
pom.xml
src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaDataConsumer.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/TopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/TopicListeners.java
src/test/java/org/oran/dmaapadapter/ApplicationTest.java
src/test/java/org/oran/dmaapadapter/IntegrationWithIcs.java
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java