diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java
index b90c611acb..af9a6a6051 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java
@@ -81,7 +81,7 @@
 	 *
 	 * The bean name of the {@link org.springframework.kafka.core.KafkaTemplate} bean that
 	 * will be used to forward the message to the retry and Dlt topics. If not specified,
-	 * a bean with name {@code retryTopicDefaultKafkaTemplate} or {@code kafkaTemplate}
+	 * a bean with name {@code defaultRetryTopicKafkaTemplate} or {@code kafkaTemplate}
 	 * will be looked up.
 	 *
 	 * @return the kafkaTemplate bean name.
diff --git a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationProviderTests.java b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationProviderTests.java
index d30e3859e2..bf621042c4 100644
--- a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationProviderTests.java
+++ b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationProviderTests.java
@@ -89,7 +89,7 @@ private Method getAnnotatedMethod(String methodName) {
 	void shouldProvideFromAnnotation() {
 
 		// setup
-		willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
+		willReturn(kafkaOperations).given(beanFactory).getBean(RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME, KafkaOperations.class);
 
 		// given
 		RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);
@@ -149,7 +149,7 @@ void shouldFindNone() {
 	void shouldProvideFromMetaAnnotation() {
 
 		// setup
-		willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
+		willReturn(kafkaOperations).given(beanFactory).getBean(RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME, KafkaOperations.class);
 
 		// given
 		RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);