Commit 9f79a901 authored by Noel Alonso's avatar Noel Alonso
Browse files

Descarta temporalmente la inserción de barcos

parent a18ec70d

vessels-commands/src/main/java/es/redmic/vesselscommands/controller/VesselTrackingController.java

+2 −2
Original line number Diff line number Diff line
@@ -29,8 +29,8 @@ public class VesselTrackingController extends CommandGeoController<VesselTrackin 
	@KafkaListener(topics = "${broker.topic.realtime.tracking.vessels}")

	public void run(AISTrackingDTO dto) throws InterruptedException {



		logger.info("Procesando barco: " + dto.getMmsi());

		vesselService.create(dto);

		// logger.info("Procesando barco: " + dto.getMmsi());

		// vesselService.create(dto);



		logger.info("Procesando track para el barco: " + dto.getMmsi() + " date: " + dto.getTstamp());

		service.create(dto);

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

+3 −2
Original line number Diff line number Diff line
@@ -30,6 +30,7 @@ spring.kafka.bootstrap-servers=${spring.kafka.bootstrap-servers} 
spring.kafka.consumer.auto-offset-reset=earliest

spring.kafka.listener.log-container-config=true

spring.kafka.listener.client-id=${spring.kafka.client-id}

spring.kafka.listener.idle-event-interval.seconds=60

spring.kafka.consumer.enable-auto-commit=true

spring.kafka.consumer.auto-commit-interval.seconds=1
@@ -47,8 +48,8 @@ spring.kafka.consumer.max-poll-records=50 
spring.kafka.producer.retries=5

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



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

spring.kafka.consumer.properties.session.timeout.ms=30000

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

spring.kafka.consumer.properties.session.timeout.ms=60000



rest.eventsource.timeout.ms=300000

process.eventsource.timeout.ms=2400000