Commit 5733c8a5 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade propiedad para disminuir registros pedidos 

De esta manera el consumidor de kafka recibe menos registros
a procesar cada vez, evitando que se produzcan errores por timeout
parent 05659012

vessels-commands/src/main/resources/application.properties

+1 −0
Original line number Diff line number Diff line
@@ -35,6 +35,7 @@ spring.kafka.producer.value-serializer=io.confluent.kafka.serializers.KafkaAvroS 
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer

spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer



spring.kafka.consumer.max-poll-records=250

spring.kafka.consumer.properties.max.poll.interval.ms=600000

spring.kafka.properties.request.timeout.ms=605000

spring.kafka.consumer.heartbeat-interval.seconds=3

vessels-view/src/main/resources/application.properties

+1 −0
Original line number Diff line number Diff line
@@ -35,6 +35,7 @@ spring.kafka.producer.value-serializer=io.confluent.kafka.serializers.KafkaAvroS 
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer

spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer



spring.kafka.consumer.max-poll-records=250

spring.kafka.consumer.properties.max.poll.interval.ms=600000

spring.kafka.properties.request.timeout.ms=605000

spring.kafka.consumer.heartbeat-interval.seconds=3