From 2b2300f804f193e3e0a7f6408e1976f474f04195 Mon Sep 17 00:00:00 2001 From: Evgeny Date: Wed, 25 Mar 2026 12:22:21 +0300 Subject: [PATCH 1/2] fix(kafka-consumer): increased max poll interval --- .../config/kafka/KafkaNotBatchProtobufConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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..6229aa44 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 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); From 31b8bd4f42be2cba05e1ba1db590c4b09a661c6a Mon Sep 17 00:00:00 2001 From: Evgeny Date: Wed, 25 Mar 2026 12:30:22 +0300 Subject: [PATCH 2/2] chore(kafka-consumer): fix spelling --- .../config/kafka/KafkaNotBatchProtobufConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 6229aa44..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 @@ -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);