Class AbstractKafkaBackOffManagerFactory

java.lang.Object
org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, KafkaBackOffManagerFactory
Direct Known Subclasses:
PartitionPausingBackOffManagerFactory

public abstract class AbstractKafkaBackOffManagerFactory extends Object implements KafkaBackOffManagerFactory, org.springframework.context.ApplicationContextAware
Base class for KafkaBackOffManagerFactory implementations.
Since:
2.7
See Also:
  • Constructor Details

    • AbstractKafkaBackOffManagerFactory

      public AbstractKafkaBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry)
      Creates an instance with the provided ListenerContainerRegistry, which will be used to fetch the MessageListenerContainer to back off.
      Parameters:
      listenerContainerRegistry - the listenerContainerRegistry to use.
    • AbstractKafkaBackOffManagerFactory

      public AbstractKafkaBackOffManagerFactory()
      Creates an instance that will retrieve the ListenerContainerRegistry from the ApplicationContext.
  • Method Details