diff --git a/kafka_message_consumer/src/main/java/ru/dankoy/kafkamessageconsumer/config/kafka/KafkaNotBatchProtobufConfig.java b/kafka_message_consumer/src/main/java/ru/dankoy/kafkamessageconsumer/config/kafka/KafkaNotBatchProtobufConfig.java
index 679cb046..9bbfbf6a 100644
--- a/kafka_message_consumer/src/main/java/ru/dankoy/kafkamessageconsumer/config/kafka/KafkaNotBatchProtobufConfig.java
+++ b/kafka_message_consumer/src/main/java/ru/dankoy/kafkamessageconsumer/config/kafka/KafkaNotBatchProtobufConfig.java
@@ -82,7 +82,7 @@ public Map<String, Object> kafkaCommonProperties(KafkaProperties kafkaProperties
     // polling interval. how many seconds consumer can work with pack of messages
     // time to process last polled records + idle between polls must be less than
     // max.poll.interval.ms.
-    props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 15_000);
+    props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 40_000);
 
     // before he hits new poll
     props.put(ConsumerConfig.RETRY_BACKOFF_MS_CONFIG, 500);
@@ -238,7 +238,7 @@ public KafkaErrorHandler errorHandlerProtobuf() {
     KafkaErrorHandler errorHandler =
         new KafkaErrorHandler(
             (consumerRecord, e) -> {
-              // logic to execute when all the retry attemps are exhausted
+              // logic to execute when all the retry attempts are exhausted
             },
             fixedBackOff);
     errorHandler.addRetryableExceptions(SocketTimeoutException.class);