K
- the key type.V
- the value type.public class ConcurrentKafkaListenerContainerFactory<K,V> extends AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>
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.
Constructor and Description |
---|
ConcurrentKafkaListenerContainerFactory() |
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.
|
createListenerContainer, getConsumerFactory, getContainerProperties, isBatchListener, setAckDiscarded, setApplicationEventPublisher, setAutoStartup, setBatchListener, setConsumerFactory, setMessageConverter, setPhase, setRecordFilterStrategy, setRecoveryCallback, setReplyTemplate, setRetryTemplate
public ConcurrentKafkaListenerContainerFactory()
public void setConcurrency(java.lang.Integer concurrency)
concurrency
- the number of consumers to create.ConcurrentMessageListenerContainer.setConcurrency(int)
protected ConcurrentMessageListenerContainer<K,V> createContainerInstance(KafkaListenerEndpoint endpoint)
AbstractKafkaListenerContainerFactory
createContainerInstance
in class AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>
endpoint
- the endpoint.protected void initializeContainer(ConcurrentMessageListenerContainer<K,V> instance)
AbstractKafkaListenerContainerFactory
Subclasses can inherit from this method to apply extra configuration if necessary.
initializeContainer
in class AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>
instance
- the container instance to configure.