micord/ervu-lkrp-av
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-9518: add comment for workaround

Browse source
This commit is contained in:
gulnaz 2025-11-01 12:13:55 +03:00
parent 3667597949
commit d94a164876
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/ru/micord/ervu/av/kafka/config/input/InputKafkaConsumerConfig.java
View file

@ -93,6 +93,8 @@ public class InputKafkaConsumerConfig {
(record, ex) -> LOGGER.error("recovery failed for message {}, {}", record.value(), ex.getMessage()), (record, ex) -> LOGGER.error("recovery failed for message {}, {}", record.value(), ex.getMessage()),
new FixedBackOff(recoveryInterval, maxRecoveryAttempts) 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); handler.setLogLevel(KafkaException.Level.TRACE);
return handler; return handler;
} }