GH-2620: Fix Call from Deprecated Method

garyrussell · garyrussell · commit c2177f63ecdb · 2023-03-16T08:30:02.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ErrorHandlingUtils.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ErrorHandlingUtils.java
@@ -72,7 +72,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r
 			CommonErrorHandler seeker, BiConsumer<ConsumerRecords<?, ?>, Exception> recoverer, LogAccessor logger,
 			KafkaException.Level logLevel, List<RetryListener> retryListeners, BinaryExceptionClassifier classifier) {
 
-		retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, null, logger,
+		retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, recoverer, logger,
 				logLevel, retryListeners, classifier, false);
 	}
 
@@ -172,7 +172,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r
 				((ConsumerPauseResumeEventPublisher) childOrSingle).publishConsumerResumedEvent(assignment2);
 			}
 		}
-	}
+	} // NOSONAR NCSS line count
 
 	private static void listen(List<RetryListener> listeners, ConsumerRecords<?, ?> records,
 			Exception thrownException, int attempt) {

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r`
`72`	`72`	`CommonErrorHandler seeker, BiConsumer<ConsumerRecords<?, ?>, Exception> recoverer, LogAccessor logger,`
`73`	`73`	`KafkaException.Level logLevel, List<RetryListener> retryListeners, BinaryExceptionClassifier classifier) {`
`74`	`74`
`75`		`- retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, null, logger,`
	`75`	`+ retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, recoverer, logger,`
`76`	`76`	`logLevel, retryListeners, classifier, false);`
`77`	`77`	`}`
`78`	`78`
`@@ -172,7 +172,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r`
`172`	`172`	`((ConsumerPauseResumeEventPublisher) childOrSingle).publishConsumerResumedEvent(assignment2);`
`173`	`173`	`}`
`174`	`174`	`}`
`175`		`- }`
	`175`	`+ } // NOSONAR NCSS line count`
`176`	`176`
`177`	`177`	`private static void listen(List<RetryListener> listeners, ConsumerRecords<?, ?> records,`
`178`	`178`	`Exception thrownException, int attempt) {`