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.
|
public ConcurrentKafkaListenerContainerFactoryConfigurer()
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