K - the key type.V - the value type.public class SimpleKafkaListenerContainerFactory<K,V> extends AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>
KafkaListenerContainerFactory implementation to build a regular
ConcurrentMessageListenerContainer.
This should be the default for most users and a good transition paths for those that are used to build such container definition manually.
| Constructor and Description |
|---|
SimpleKafkaListenerContainerFactory() |
| 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.
|
void |
setRecentOffset(java.lang.Long recentOffset)
Specify the offset lag from the end of commit.
|
createListenerContainer, getConsumerFactory, setAckCount, setAckMode, setAutoStartup, setConsumerFactory, setErrorHandler, setPhase, setPollTimeout, setTaskExecutorpublic void setConcurrency(java.lang.Integer concurrency)
concurrency - the number of consumers to create.ConcurrentMessageListenerContainer.setConcurrency(int)public void setRecentOffset(java.lang.Long recentOffset)
recentOffset - the recent offset.ConcurrentMessageListenerContainer.setRecentOffset(long)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.