Skip to content

Commit c881f2d

Browse files
JeonDaehongspring-builds
authored andcommitted
GH-3514: RetryableTopic javadoc/test update for defaultRetryTopicKafkaTemplate
Fixes: #3514 #3514 * Fix: Replace `retryTopicDefaultKafkaTemplate` with `defaultRetryTopicKafkaTemplate` in javadocs * Fix: Replace `retryTopicDefaultKafkaTemplate` with `RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME` in Test Code (cherry picked from commit f1cb003)
1 parent dc4a10f commit c881f2d

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@
7777
*
7878
* The bean name of the {@link org.springframework.kafka.core.KafkaTemplate} bean that
7979
* will be used to forward the message to the retry and Dlt topics. If not specified,
80-
* a bean with name {@code retryTopicDefaultKafkaTemplate} or {@code kafkaTemplate}
80+
* a bean with name {@code defaultRetryTopicKafkaTemplate} or {@code kafkaTemplate}
8181
* will be looked up.
8282
*
8383
* @return the kafkaTemplate bean name.

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ private Method getAnnotatedMethod(String methodName) {
9797
void shouldProvideFromAnnotation() {
9898

9999
// setup
100-
willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
100+
willReturn(kafkaOperations).given(beanFactory).getBean(RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME, KafkaOperations.class);
101101

102102
// given
103103
RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);
@@ -148,7 +148,7 @@ void shouldFindNone() {
148148
void shouldProvideFromMetaAnnotation() {
149149

150150
// setup
151-
willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
151+
willReturn(kafkaOperations).given(beanFactory).getBean(RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME, KafkaOperations.class);
152152

153153
// given
154154
RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);

0 commit comments

Comments
 (0)