Fixes compile error.

spring-projects · Oct 10, 2024 · c0fea39 · c0fea39
1 parent 08e7721
commit c0fea39
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java b/...main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java
@@ -884,7 +884,7 @@ private boolean rawByParameterIsType(Type parameterType, Type type) {
 		return parameterType instanceof ParameterizedType pType && pType.getRawType().equals(type);
 	}
 
-	protected void setCallbackForAsyncFailure(BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
+	protected void setAsyncFailureCallback(BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
 		this.callbackForAsyncFailureQueue = asyncRetryCallback;
 	}
 

diff --git a/...ava/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java b/...ava/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java
@@ -89,6 +89,6 @@ public void onMessage(ConsumerRecord<K, V> record, @Nullable Acknowledgment ackn
 	@Override
 	public void setCallbackForAsyncFailure(
 			BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
-		super.setCallbackForAsyncFailure(asyncRetryCallback);
+		setAsyncFailureCallback(asyncRetryCallback);
 	}
 }