Class ContainerPartitionPausingBackOffManagerFactory
java.lang.Object
org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
org.springframework.kafka.listener.ContainerPartitionPausingBackOffManagerFactory
- All Implemented Interfaces:
Aware
,ApplicationContextAware
,KafkaBackOffManagerFactory
public class ContainerPartitionPausingBackOffManagerFactory
extends AbstractKafkaBackOffManagerFactory
A factory for
ContainerPartitionPausingBackOffManager
.- Since:
- 2.9
- Author:
- Gary Russell
-
Constructor Summary
ConstructorsConstructorDescriptionContainerPartitionPausingBackOffManagerFactory
(ListenerContainerRegistry listenerContainerRegistry, ApplicationContext applicationContext) Construct an instance with the provided properties. -
Method Summary
Modifier and TypeMethodDescriptionprotected KafkaConsumerBackoffManager
doCreateManager
(ListenerContainerRegistry registry) void
setBackOffHandler
(BackOffHandler backOffHandler) Set the back off handler to use in the created handlers.Methods inherited from class org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
create, getBean, getListenerContainerRegistry, setApplicationContext, setListenerContainerRegistry
-
Constructor Details
-
ContainerPartitionPausingBackOffManagerFactory
public ContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry, ApplicationContext applicationContext) Construct an instance with the provided properties.- Parameters:
listenerContainerRegistry
- the registry.applicationContext
- the application context.
-
-
Method Details
-
doCreateManager
- Specified by:
doCreateManager
in classAbstractKafkaBackOffManagerFactory
-
setBackOffHandler
Set the back off handler to use in the created handlers.- Parameters:
backOffHandler
- the handler.
-