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 Summary

Constructors

Constructor and Description
ConcurrentKafkaListenerContainerFactoryConfigurer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentKafkaListenerContainerFactoryConfigurer

public ConcurrentKafkaListenerContainerFactoryConfigurer()

Method Detail

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