Package org.springframework.kafka.listener

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

Constructors

Constructor	Description
ContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry, ApplicationContext applicationContext)	Construct an instance with the provided properties.

Method Summary

Modifier and Type	Method	Description
protected 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

protected KafkaConsumerBackoffManager doCreateManager(ListenerContainerRegistry registry)

Specified by:

doCreateManager in class AbstractKafkaBackOffManagerFactory

setBackOffHandler

public void setBackOffHandler(BackOffHandler backOffHandler)

Set the back off handler to use in the created handlers.

Parameters:

backOffHandler - the handler.