From b53c9348b3f52bc2ef626a5c68c8a9a6ca7d6645 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Sat, 5 Oct 2019 09:15:57 -0400 Subject: [PATCH] Fix Sonar issues --- .../kafka/listener/DefaultAfterRollbackProcessor.java | 4 ++-- .../springframework/kafka/listener/FailedRecordProcessor.java | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) 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); } /**