Add test cases.

Author: chickenchickenlove

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java

@@ -911,10 +911,6 @@ public void acknowledge() {
 
 	}
 
-	public void setAsyncRetryCallback(BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
-		this.asyncRetryCallback = asyncRetryCallback;
-	}
-
 	public void putInAsyncFailureQueue(java.util.function.Consumer<FailedRecordTuple> callbackForAsyncFailureQueue) {
 		this.callbackForAsyncFailureQueue = callbackForAsyncFailureQueue;
 	}

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java

@@ -21,6 +21,7 @@
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 
+import org.springframework.kafka.core.FailedRecordTuple;
 import org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener;
 import org.springframework.kafka.listener.KafkaListenerErrorHandler;
 import org.springframework.kafka.support.Acknowledgment;
@@ -85,4 +86,9 @@ public void onMessage(ConsumerRecord<K, V> record, @Nullable Acknowledgment ackn
 		invoke(record, acknowledgment, consumer, message);
 	}
 
+	@Override
+	public void setCallbackForAsyncFailureQueue(
+			java.util.function.Consumer<FailedRecordTuple> asyncRetryCallback) {
+		putInAsyncFailureQueue(asyncRetryCallback);
+	}
 }

spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncCompletableFutureRetryTopicClassLevelIntegrationTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2021 the original author or authors.
+ * Copyright 2018-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.