diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java index def0f63f..4afcb296 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java @@ -167,8 +167,8 @@ public class DefaultAfterRollbackProcessor extends FailedRecordProcessor i * @see #setKafkaTemplate(KafkaTemplate) */ @Override - public void setCommitRecovered(boolean commitRecovered) { - super.setCommitRecovered(commitRecovered); // NOSONAR enhanced javadoc + public void setCommitRecovered(boolean commitRecovered) { // NOSONAR enhanced javadoc + super.setCommitRecovered(commitRecovered); } /** diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordProcessor.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordProcessor.java index eff9dc02..98075a63 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordProcessor.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordProcessor.java @@ -195,8 +195,7 @@ public abstract class FailedRecordProcessor { classified.put(MethodArgumentResolutionException.class, false); classified.put(NoSuchMethodException.class, false); classified.put(ClassCastException.class, false); - ExtendedBinaryExceptionClassifier defaultClassifier = new ExtendedBinaryExceptionClassifier(classified, true); - return defaultClassifier; + return new ExtendedBinaryExceptionClassifier(classified, true); } /**