From 7a5c200f371c8e6ad0fe3ad7671777ac533b0663 Mon Sep 17 00:00:00 2001 From: Florian THIERRY Date: Thu, 6 May 2021 10:32:40 +0200 Subject: [PATCH] Add test properties for avro consumer IT. --- .../resources/application-test.yml | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) diff --git a/kafka-consumer/src/integration-test/resources/application-test.yml b/kafka-consumer/src/integration-test/resources/application-test.yml index 8d0d79c..064d05a 100644 --- a/kafka-consumer/src/integration-test/resources/application-test.yml +++ b/kafka-consumer/src/integration-test/resources/application-test.yml @@ -3,3 +3,26 @@ server: bootstrapAddress: "${spring.embedded.kafka.brokers:}" topic: topic-test groupId: groupId-test + +spring: + kafka: + consumer: + auto-offset-reset: earliest + group-id: groupId-test + client-id: test-export-entity + key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer + value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer + properties: + spring.deserializer.key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer + spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer + producer: + key-serializer: org.apache.kafka.common.serialization.StringSerializer + value-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer + properties: # for KafkaAvroDeserializer + # this value isn’t used but is still required + schema.registry.url: mock://localhost:8083 + specific.avro.reader: true + log.retention.hours: -1 # Disable log retention as it doesn't work on Windows filesystem... + log.cleaner.enable: false + main: + allow-bean-definition-overriding: true \ No newline at end of file