From d94a164876677c8b4dc5932999317c31d7551159 Mon Sep 17 00:00:00 2001 From: gulnaz Date: Sat, 1 Nov 2025 12:13:55 +0300 Subject: [PATCH] SUPPORT-9518: add comment for workaround --- .../ervu/av/kafka/config/input/InputKafkaConsumerConfig.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/ru/micord/ervu/av/kafka/config/input/InputKafkaConsumerConfig.java b/src/main/java/ru/micord/ervu/av/kafka/config/input/InputKafkaConsumerConfig.java index 2900f58..bacb0c6 100644 --- a/src/main/java/ru/micord/ervu/av/kafka/config/input/InputKafkaConsumerConfig.java +++ b/src/main/java/ru/micord/ervu/av/kafka/config/input/InputKafkaConsumerConfig.java @@ -93,6 +93,8 @@ public class InputKafkaConsumerConfig { (record, ex) -> LOGGER.error("recovery failed for message {}, {}", record.value(), ex.getMessage()), new FixedBackOff(recoveryInterval, maxRecoveryAttempts) ); + // workaround to hide redundant logging + // https://github.com/spring-projects/spring-kafka/issues/3409#issuecomment-2276147858 handler.setLogLevel(KafkaException.Level.TRACE); return handler; }