commit ffe0e1ee121e2ca89f82824f193ed0a0e599a2c0
author raviteja.karumuri <raviteja.karumuri@est.tech> Thu Jun 29 13:57:40 2023 +0100
committer raviteja.karumuri <raviteja.karumuri@est.tech> Thu Jun 29 15:06:34 2023 +0100
tree 71022e9e0f1e564996cd535d5c13bcc5915d8f58
parent 300860865a8dd616083543f7c88cf2c8233c2701

Updating the Kafka listener compliance to could events and legacy

# Added filter property to the legay(DMIAsync) Consumer
# Added containerFactory property to the CloudEvent(DataOperation) consumer to use 'cloudEventDeserializtion'

Issue-ID: CPS-1746
Signed-off-by: raviteja.karumuri <raviteja.karumuri@est.tech>
Change-Id: I73315b816eb6446b7e163fd8779bc35fd6cbef63

cps-ncmp-service/src/test/resources/application.yml

diff --git a/cps-ncmp-service/src/test/resources/application.yml b/cps-ncmp-service/src/test/resources/application.yml
index df34f84..edbd702 100644
--- a/cps-ncmp-service/src/test/resources/application.yml
+++ b/cps-ncmp-service/src/test/resources/application.yml
@@ -21,6 +21,7 @@
         producer:
             value-serializer: io.cloudevents.kafka.CloudEventSerializer
         consumer:
+            value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
             properties:
                 spring.deserializer.value.delegate.class: io.cloudevents.kafka.CloudEventDeserializer
 
@@ -54,4 +55,4 @@
   mode:
     kubernetes:
       enabled: false
-      service-name: "cps-and-ncmp-service"
\ No newline at end of file
+      service-name: "cps-and-ncmp-service"