public class ConcurrentKafkaListenerContainerFactoryConfigurer extends Object
ConcurrentKafkaListenerContainerFactory
with sensible defaults.Constructor and Description |
---|
ConcurrentKafkaListenerContainerFactoryConfigurer() |
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.
|
void |
setCommonErrorHandler(org.springframework.kafka.listener.CommonErrorHandler commonErrorHandler)
Set the
CommonErrorHandler to use. |
public ConcurrentKafkaListenerContainerFactoryConfigurer()
public void setCommonErrorHandler(org.springframework.kafka.listener.CommonErrorHandler commonErrorHandler)
CommonErrorHandler
to use.commonErrorHandler
- the error handler.public void configure(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<Object,Object> listenerFactory, org.springframework.kafka.core.ConsumerFactory<Object,Object> consumerFactory)
listenerFactory
- the ConcurrentKafkaListenerContainerFactory
instance
to configureconsumerFactory
- the ConsumerFactory
to use