Class ContainerPartitionPausingBackOffManagerFactory
- java.lang.Object
-
- org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
-
- org.springframework.kafka.listener.ContainerPartitionPausingBackOffManagerFactory
-
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.context.ApplicationContextAware,KafkaBackOffManagerFactory
public class ContainerPartitionPausingBackOffManagerFactory extends AbstractKafkaBackOffManagerFactory
A factory forContainerPartitionPausingBackOffManager.- Since:
- 2.9
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Constructor Description ContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry, org.springframework.context.ApplicationContext applicationContext)Construct an instance with the provided properties.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected KafkaConsumerBackoffManagerdoCreateManager(ListenerContainerRegistry registry)voidsetBackOffHandler(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 Detail
-
ContainerPartitionPausingBackOffManagerFactory
public ContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry, org.springframework.context.ApplicationContext applicationContext)
Construct an instance with the provided properties.- Parameters:
listenerContainerRegistry- the registry.applicationContext- the application context.
-
-
Method Detail
-
doCreateManager
protected KafkaConsumerBackoffManager doCreateManager(ListenerContainerRegistry registry)
- Specified by:
doCreateManagerin classAbstractKafkaBackOffManagerFactory
-
setBackOffHandler
public void setBackOffHandler(BackOffHandler backOffHandler)
Set the back off handler to use in the created handlers.- Parameters:
backOffHandler- the handler.
-
-