Add kafka listener for data updated events

See "Running via Docker Compose" section from README.md file to have an
example of event processing

Issue-ID: CPS-371
Signed-off-by: Bruno Sakoto <bruno.sakoto@bell.ca>
Change-Id: Id3abfa32fb04e07102a5f28e6e43a9b533391188

1 files changed, 28 insertions, 8 deletions

diff --git a/src/test/resources/application.yml b/src/test/resources/application.yml
index afaff6c..3ac13a9 100644
--- a/src/test/resources/application.yml
+++ b/src/test/resources/application.yml
@@ -20,17 +20,37 @@ server:
 spring:
     datasource:
         url: ${DB_URL}
-        password: ${DB_PASSWORD}
         username: ${DB_USERNAME}
+        password: ${DB_PASSWORD}
     liquibase:
         change-log: classpath:/db/changelog/changelog-master.xml
     jpa:
-        open-in-view: false
         properties:
-            hibernate:
-                dialect: org.hibernate.dialect.PostgreSQLDialect
+            hibernate.dialect: org.hibernate.dialect.PostgreSQLDialect
+            hibernate.format_sql: true
+            hibernate.generate_statistics: false
+    kafka:
+        bootstrap-servers: localhost:9092
+        security:
+            protocol: PLAINTEXT
+        consumer:
+            group-id: cps-temporal-group
+            # Configures the Spring Kafka ErrorHandlingDeserializer that delegates to the 'real' deserializers
+            # See https://docs.spring.io/spring-kafka/docs/2.5.11.RELEASE/reference/html/#error-handling-deserializer
+            # and https://www.confluent.io/blog/spring-kafka-can-your-kafka-consumers-handle-a-poison-pill/
+            key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
+            value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
+            auto-offset-reset: earliest
+            properties:
+                spring.deserializer.key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer
+                spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
+                spring.json.value.default.type: org.onap.cps.event.model.CpsDataUpdatedEvent
+        # Following is not cps-temporal configuration. It is configuration for the producer used for integration tests
+        producer:
+            key-serializer: org.apache.kafka.common.serialization.StringSerializer
+            value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
 
-logging:
-    level:
-        org:
-            springframework: INFO
+app:
+    listener:
+        data-updated:
+            topic: cps.cfg-state-events