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 for
ContainerPartitionPausingBackOffManager.- Since:
- 2.9
-
Constructor Summary
ConstructorsConstructorDescriptionContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry, org.springframework.context.ApplicationContext applicationContext) Construct an instance with the provided properties. -
Method Summary
Modifier and TypeMethodDescriptionprotected 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 Details
-
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 Details
-
doCreateManager
- Specified by:
doCreateManagerin classAbstractKafkaBackOffManagerFactory
-
setBackOffHandler
Set the back off handler to use in the created handlers.- Parameters:
backOffHandler- the handler.
-