Changed priniples for zipping output 67/9467/3
authorPatrikBuhr <patrik.buhr@est.tech>
Wed, 2 Nov 2022 13:03:44 +0000 (14:03 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Thu, 3 Nov 2022 07:42:39 +0000 (08:42 +0100)
commit03aca86a9766e1283b3bd3a09c3c602a684565b1
treee1e24626e2e527e21c26ee4cc3471c44734cb271
parenta320b4093cc0f7076e0599dcad8f9fd33f7b44f6
Changed priniples for zipping output

The descition of zipping the ouput is taken by the producer instead of the consumer.
The consumer will get a Kafkaheader named "gzip" if the output is gzipped.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-773
Change-Id: I3016313bbb8a833c14c651492da7a87c37e71e31
14 files changed:
config/application.yaml
src/main/java/org/oran/dmaapadapter/configuration/ApplicationConfig.java
src/main/java/org/oran/dmaapadapter/filter/Filter.java
src/main/java/org/oran/dmaapadapter/repository/Job.java
src/main/java/org/oran/dmaapadapter/tasks/DmaapTopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/JobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/TopicListener.java
src/main/resources/typeSchemaPmData.json
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java
src/test/java/org/oran/dmaapadapter/filter/JsltFilterTest.java
src/test/java/org/oran/dmaapadapter/filter/JsonPathFilterTest.java
src/test/java/org/oran/dmaapadapter/filter/PmReportFilterTest.java