|
33 | 33 | import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
|
34 | 34 | import org.springframework.kafka.config.KafkaListenerContainerFactory;
|
35 | 35 | import org.springframework.kafka.config.KafkaListenerEndpoint;
|
36 |
| -import org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener; |
37 | 36 | import org.springframework.kafka.listener.CommonErrorHandler;
|
38 | 37 | import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
|
39 | 38 | import org.springframework.kafka.listener.ContainerProperties;
|
40 | 39 | import org.springframework.kafka.listener.DeadLetterPublishingRecoverer;
|
41 | 40 | import org.springframework.kafka.listener.DefaultErrorHandler;
|
42 | 41 | import org.springframework.kafka.listener.KafkaConsumerBackoffManager;
|
| 42 | +import org.springframework.kafka.listener.MessageListener; |
43 | 43 | import org.springframework.kafka.listener.adapter.KafkaBackoffAwareMessageListenerAdapter;
|
44 | 44 | import org.springframework.kafka.support.TopicPartitionOffset;
|
45 | 45 | import org.springframework.util.Assert;
|
@@ -252,8 +252,8 @@ protected DefaultErrorHandler createDefaultErrorHandlerInstance(DeadLetterPublis
|
252 | 252 |
|
253 | 253 | protected void setupBackoffAwareMessageListenerAdapter(ConcurrentMessageListenerContainer<?, ?> container,
|
254 | 254 | Configuration configuration, boolean isSetContainerProperties) {
|
255 |
| - AcknowledgingConsumerAwareMessageListener<?, ?> listener = checkAndCast(container.getContainerProperties() |
256 |
| - .getMessageListener(), AcknowledgingConsumerAwareMessageListener.class); |
| 255 | + MessageListener<?, ?> listener = checkAndCast(container.getContainerProperties() |
| 256 | + .getMessageListener(), MessageListener.class); |
257 | 257 |
|
258 | 258 | if (isSetContainerProperties && !configuration.backOffValues.isEmpty()) {
|
259 | 259 | configurePollTimeoutAndIdlePartitionInterval(container, configuration);
|
|
0 commit comments