GH-2620: Fix Call from Deprecated Method

garyrussell · garyrussell · commit 00afc59adfa7 · 2023-03-16T08:31:40.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
@@ -119,7 +119,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r
 			KafkaException.Level logLevel, @Nullable List<RetryListener> retryListenersArg,
 			BinaryExceptionClassifier classifier) {
 
-		retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, null, logger,
+		retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, recoverer, logger,
 				logLevel, retryListenersArg, classifier, false);
 	}
 
@@ -224,7 +224,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r
 				((ConsumerPauseResumeEventPublisher) childOrSingle).publishConsumerResumedEvent(assignment2);
 			}
 		}
-	}
+	} // NOSONAR NCSS line count
 
 	private static void listen(@Nullable List<RetryListener> listeners, ConsumerRecords<?, ?> records,
 			Exception thrownException, int attempt) {

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r`
`119`	`119`	`KafkaException.Level logLevel, @Nullable List<RetryListener> retryListenersArg,`
`120`	`120`	`BinaryExceptionClassifier classifier) {`
`121`	`121`
`122`		`- retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, null, logger,`
	`122`	`+ retryBatch(thrownException, records, consumer, container, invokeListener, backOff, seeker, recoverer, logger,`
`123`	`123`	`logLevel, retryListenersArg, classifier, false);`
`124`	`124`	`}`
`125`	`125`
`@@ -224,7 +224,7 @@ public static void retryBatch(Exception thrownException, ConsumerRecords<?, ?> r`
`224`	`224`	`((ConsumerPauseResumeEventPublisher) childOrSingle).publishConsumerResumedEvent(assignment2);`
`225`	`225`	`}`
`226`	`226`	`}`
`227`		`- }`
	`227`	`+ } // NOSONAR NCSS line count`
`228`	`228`
`229`	`229`	`private static void listen(@Nullable List<RetryListener> listeners, ConsumerRecords<?, ?> records,`
`230`	`230`	`Exception thrownException, int attempt) {`