Add test properties for avro consumer IT.
This commit is contained in:
@@ -3,3 +3,26 @@ server:
|
|||||||
bootstrapAddress: "${spring.embedded.kafka.brokers:}"
|
bootstrapAddress: "${spring.embedded.kafka.brokers:}"
|
||||||
topic: topic-test
|
topic: topic-test
|
||||||
groupId: groupId-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
|
||||||
Reference in New Issue
Block a user