diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/config/KafkaConfig.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/config/KafkaConfig.java index e5bdfcc49..cccf703aa 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/config/KafkaConfig.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/config/KafkaConfig.java @@ -33,7 +33,7 @@ public class KafkaConfig { public KafkaConfig(ClearingServiceSettings settings) { this.kafkaSettings = settings.getKafkaConsumer(); - Integer gtwTimeout = settings.getSessionStage().getInspectionGatewayTimeout(); + Integer gtwTimeout = settings.getSessionStage() == null ? null : settings.getSessionStage().getInspectionGatewayTimeout(); if (gtwTimeout != null) { int maxPollIntervalMs = gtwTimeout * 1000 + 1000; log.debug("setting max.poll.interval.ms {}", maxPollIntervalMs);