Package org.springframework.kafka.config

Class ConcurrentKafkaListenerContainerFactory<K,V>

java.lang.Object

org.springframework.kafka.config.AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>

org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>>

public class ConcurrentKafkaListenerContainerFactory<K,V>
extends AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>

A KafkaListenerContainerFactory implementation to build a ConcurrentMessageListenerContainer.

This should be the default for most users and a good transition paths for those that are used to building such container definitions manually. This factory is primarily for building containers for KafkaListener annotated methods but can also be used to create any container. Only containers for KafkaListener annotated methods are added to the KafkaListenerEndpointRegistry.

Author:

Stephane Nicoll, Gary Russell, Artem Bilan, Murali Reddy

Field Summary

Fields inherited from class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

logger

Constructor Summary

Constructors

Constructor	Description
ConcurrentKafkaListenerContainerFactory()

Method Summary

Modifier and Type	Method	Description
protected ConcurrentMessageListenerContainer<K,V>	createContainerInstance(KafkaListenerEndpoint endpoint)	Create an empty container instance.
protected void	initializeContainer(ConcurrentMessageListenerContainer<K,V> instance, KafkaListenerEndpoint endpoint)	Further initialize the specified container.
void	setConcurrency(java.lang.Integer concurrency)	Specify the container concurrency.

Methods inherited from class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

afterPropertiesSet, createContainer, createContainer, createContainer, createListenerContainer, getConsumerFactory, getContainerProperties, isBatchListener, setAckDiscarded, setAfterRollbackProcessor, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBatchErrorHandler, setBatchListener, setBatchToRecordAdapter, setConsumerFactory, setContainerCustomizer, setErrorHandler, setMessageConverter, setMissingTopicsFatal, setPhase, setRecordFilterStrategy, setRecordInterceptor, setRecoveryCallback, setReplyHeadersConfigurer, setReplyTemplate, setRetryTemplate, setStatefulRetry

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentKafkaListenerContainerFactory

public ConcurrentKafkaListenerContainerFactory()

Method Detail

setConcurrency

public void setConcurrency(java.lang.Integer concurrency)

Specify the container concurrency.

Parameters:

concurrency - the number of consumers to create.

See Also:

ConcurrentMessageListenerContainer.setConcurrency(int)

createContainerInstance

protected ConcurrentMessageListenerContainer<K,V> createContainerInstance(KafkaListenerEndpoint endpoint)

Description copied from class: AbstractKafkaListenerContainerFactory

Create an empty container instance.

Specified by:

createContainerInstance in class AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>

Parameters:

endpoint - the endpoint.

Returns:

the new container instance.

initializeContainer

protected void initializeContainer(ConcurrentMessageListenerContainer<K,V> instance,
                                   KafkaListenerEndpoint endpoint)

Description copied from class: AbstractKafkaListenerContainerFactory

Further initialize the specified container.

Subclasses can inherit from this method to apply extra configuration if necessary.

Overrides:

initializeContainer in class AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>

Parameters:

instance - the container instance to configure.

endpoint - the endpoint.