diff --git a/config-repo/pcp-route-processing-service.yaml b/config-repo/pcp-route-processing-service.yaml index 5828e64..f17beee 100644 --- a/config-repo/pcp-route-processing-service.yaml +++ b/config-repo/pcp-route-processing-service.yaml @@ -54,6 +54,13 @@ app: max-attempts: 3 backoff-ms: 1000 max-backoff-ms: 30000 + outbox: + enabled: true + batch-size: 50 + fixed-delay-ms: 1000 + lock-timeout-ms: 60000 + initial-backoff-ms: 1000 + max-backoff-ms: 60000 kafka: topics: input: pcp.request.survey-georeference.v1 diff --git a/services/pcp-route-processing-service/src/main/kotlin/space/nstart/pcp/routepassportconsumer/RoutePassportConsumerApplication.kt b/services/pcp-route-processing-service/src/main/kotlin/space/nstart/pcp/routepassportconsumer/RoutePassportConsumerApplication.kt index 09ee37b..a9e6946 100644 --- a/services/pcp-route-processing-service/src/main/kotlin/space/nstart/pcp/routepassportconsumer/RoutePassportConsumerApplication.kt +++ b/services/pcp-route-processing-service/src/main/kotlin/space/nstart/pcp/routepassportconsumer/RoutePassportConsumerApplication.kt @@ -4,6 +4,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication import org.springframework.boot.context.properties.ConfigurationPropertiesScan import org.springframework.boot.runApplication import org.springframework.kafka.annotation.EnableKafka +import org.springframework.scheduling.annotation.EnableScheduling /** * Главный класс Spring Boot приложения. @@ -13,6 +14,7 @@ import org.springframework.kafka.annotation.EnableKafka @ConfigurationPropertiesScan @SpringBootApplication @EnableKafka +@EnableScheduling class RoutePassportConsumerApplication /**