Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Widen Delegate Type for KafkaBackoffAwareMLAdapter

Browse Source 
Setting up the backoff aware message listener adapter should work for any message listener.
This commit is contained in:
Filip Hrisafov
2022-06-21 22:32:40 +02:00
committed by Gary Russell
parent b57c608fc7
commit 596f7d940c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-kafka/src/main/java/org/springframework/kafka/retrytopic/ListenerContainerFactoryConfigurer.java
View File

@@ -33,13 +33,13 @@ import org.springframework.kafka.KafkaException;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.config.KafkaListenerContainerFactory;
import org.springframework.kafka.config.KafkaListenerEndpoint;
import org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener;
import org.springframework.kafka.listener.CommonErrorHandler;
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
import org.springframework.kafka.listener.ContainerProperties;
import org.springframework.kafka.listener.DeadLetterPublishingRecoverer;
import org.springframework.kafka.listener.DefaultErrorHandler;
import org.springframework.kafka.listener.KafkaConsumerBackoffManager;
import org.springframework.kafka.listener.MessageListener;
import org.springframework.kafka.listener.adapter.KafkaBackoffAwareMessageListenerAdapter;
import org.springframework.kafka.support.TopicPartitionOffset;
import org.springframework.util.Assert;
@@ -252,8 +252,8 @@ public class ListenerContainerFactoryConfigurer {
protected void setupBackoffAwareMessageListenerAdapter(ConcurrentMessageListenerContainer<?, ?> container,
Configuration configuration, boolean isSetContainerProperties) {
AcknowledgingConsumerAwareMessageListener<?, ?> listener = checkAndCast(container.getContainerProperties()
.getMessageListener(), AcknowledgingConsumerAwareMessageListener.class);
MessageListener<?, ?> listener = checkAndCast(container.getContainerProperties()
.getMessageListener(), MessageListener.class);
if (isSetContainerProperties && !configuration.backOffValues.isEmpty()) {
configurePollTimeoutAndIdlePartitionInterval(container, configuration);