Skip to content

Commit f9f6a55

Browse files
Aleksei-Chgaryrussell
authored andcommitted
@RetryableTopic More SpEL Support
@RetryableTopic Support SpEL for listenerContainerFactory and kafkaTemplate properties
1 parent 5c70ec1 commit f9f6a55

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ public RetryTopicConfiguration processAnnotation(String[] topics, Method method,
134134
.dltSuffix(resolveExpressionAsString(annotation.dltTopicSuffix(), "dltTopicSuffix"))
135135
.dltHandlerMethod(getDltProcessor(method, bean))
136136
.includeTopics(Arrays.asList(topics))
137-
.listenerFactory(annotation.listenerContainerFactory())
137+
.listenerFactory(resolveExpressionAsString(annotation.listenerContainerFactory(), "listenerContainerFactory"))
138138
.autoCreateTopics(resolveExpressionAsBoolean(annotation.autoCreateTopics(), "autoCreateTopics"),
139139
resolveExpressionAsInteger(annotation.numPartitions(), "numPartitions", true),
140140
resolveExpressionAsShort(annotation.replicationFactor(), "replicationFactor", true))
@@ -146,7 +146,7 @@ public RetryTopicConfiguration processAnnotation(String[] topics, Method method,
146146
.autoStartDltHandler(autoStartDlt)
147147
.setTopicSuffixingStrategy(annotation.topicSuffixingStrategy())
148148
.timeoutAfter(timeout)
149-
.create(getKafkaTemplate(annotation.kafkaTemplate(), topics));
149+
.create(getKafkaTemplate(resolveExpressionAsString(annotation.kafkaTemplate(), "kafkaTemplate"), topics));
150150
}
151151

152152
private SleepingBackOffPolicy<?> createBackoffFromAnnotation(Backoff backoff, BeanFactory beanFactory) { // NOSONAR

0 commit comments

Comments
 (0)