Package org.springframework.boot.autoconfigure.kafka

Class ConcurrentKafkaListenerContainerFactoryConfigurer

java.lang.Object
org.springframework.boot.autoconfigure.kafka.ConcurrentKafkaListenerContainerFactoryConfigurer
public class ConcurrentKafkaListenerContainerFactoryConfigurer extends Object
Configure ConcurrentKafkaListenerContainerFactory with sensible defaults.
Since:
1.5.0
Author:
Gary Russell, Eddú Meléndez

  • Constructor Details

    • ConcurrentKafkaListenerContainerFactoryConfigurer

      public ConcurrentKafkaListenerContainerFactoryConfigurer()

  • Method Details

    • setCommonErrorHandler

      public void setCommonErrorHandler(org.springframework.kafka.listener.CommonErrorHandler commonErrorHandler)
      Set the CommonErrorHandler to use.
      Parameters:
      commonErrorHandler - the error handler.
      Since:
      2.6.0

    • configure

      public void configure(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<Object,Object> listenerFactory, org.springframework.kafka.core.ConsumerFactory<Object,Object> consumerFactory)
      Configure the specified Kafka listener container factory. The factory can be further tuned and default settings can be overridden.
      Parameters:
      listenerFactory - the ConcurrentKafkaListenerContainerFactory instance to configure
      consumerFactory - the ConsumerFactory to use