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, setAfterRollbackProcessor, setApplicationEventPublisher, setAutoStartup, setBatchListener, setConsumerFactory, setMessageConverter, setPhase, setRecordFilterStrategy, setRecoveryCallback, setReplyTemplate, setRetryTemplatepublic 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)
AbstractKafkaListenerContainerFactorycreateContainerInstance in class AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>endpoint - the endpoint.protected void initializeContainer(ConcurrentMessageListenerContainer<K,V> instance)
AbstractKafkaListenerContainerFactorySubclasses 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.