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.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 build such container definitions manually.

Author:

Stephane Nicoll, Gary Russell, Artem Bilan, Murali Reddy

Constructor Summary

Constructors

Constructor and Description
ConcurrentKafkaListenerContainerFactory()

Method Summary

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

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

createListenerContainer, getConsumerFactory, getContainerProperties, isBatchListener, setAckDiscarded, setApplicationEventPublisher, setAutoStartup, setBatchListener, setConsumerFactory, setMessageConverter, setPhase, setRecordFilterStrategy, setRecoveryCallback, setReplyTemplate, setRetryTemplate

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)

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.