C - the AbstractMessageListenerContainer implementation type.K - the key type.V - the value type.public abstract class AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>,K,V> extends java.lang.Object implements KafkaListenerContainerFactory<C>
KafkaListenerContainerFactory for Spring's base container implementation.AbstractMessageListenerContainer| Constructor and Description |
|---|
AbstractKafkaListenerContainerFactory() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract C |
createContainerInstance(KafkaListenerEndpoint endpoint)
Create an empty container instance.
|
C |
createListenerContainer(KafkaListenerEndpoint endpoint)
Create a
MessageListenerContainer for the given KafkaListenerEndpoint. |
ConsumerFactory<K,V> |
getConsumerFactory() |
protected void |
initializeContainer(C instance)
Further initialize the specified container.
|
void |
setAckCount(java.lang.Integer ackCount)
Specify an
ackCount to use. |
void |
setAckMode(AbstractMessageListenerContainer.AckMode ackMode)
Specify an
AbstractMessageListenerContainer.AckMode to use. |
void |
setAutoStartup(java.lang.Boolean autoStartup)
Specify an
autoStartup boolean flag. |
void |
setConsumerFactory(ConsumerFactory<K,V> consumerFactory)
Specify a
ConsumerFactory to use. |
void |
setErrorHandler(ErrorHandler errorHandler)
Specify an
ErrorHandler to use. |
void |
setPhase(int phase)
Specify a
phase to use. |
void |
setPollTimeout(java.lang.Long pollTimeout)
Specify a
pollTimeout to use. |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor)
Specify an
Executor to use. |
public AbstractKafkaListenerContainerFactory()
public void setConsumerFactory(ConsumerFactory<K,V> consumerFactory)
ConsumerFactory to use.consumerFactory - The consumer factory.public ConsumerFactory<K,V> getConsumerFactory()
public void setErrorHandler(ErrorHandler errorHandler)
ErrorHandler to use.errorHandler - The error handler.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
Executor to use.taskExecutor - the Executor to use.setTaskExecutor(java.util.concurrent.Executor)public void setAutoStartup(java.lang.Boolean autoStartup)
autoStartup boolean flag.autoStartup - true for auto startup.AbstractMessageListenerContainer.setAutoStartup(boolean)public void setPhase(int phase)
phase to use.phase - The phase.AbstractMessageListenerContainer.setPhase(int)public void setAckCount(java.lang.Integer ackCount)
ackCount to use.ackCount - the ack count.AbstractMessageListenerContainer.setAckCount(int)public void setAckMode(AbstractMessageListenerContainer.AckMode ackMode)
AbstractMessageListenerContainer.AckMode to use.ackMode - the ack mode.AbstractMessageListenerContainer.setAckMode(AckMode)public void setPollTimeout(java.lang.Long pollTimeout)
pollTimeout to use.pollTimeout - the poll timeoutAbstractMessageListenerContainer.setPollTimeout(long)public C createListenerContainer(KafkaListenerEndpoint endpoint)
KafkaListenerContainerFactoryMessageListenerContainer for the given KafkaListenerEndpoint.createListenerContainer in interface KafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>>endpoint - the endpoint to configureprotected abstract C createContainerInstance(KafkaListenerEndpoint endpoint)
endpoint - the endpoint.protected void initializeContainer(C instance)
Subclasses can inherit from this method to apply extra configuration if necessary.
instance - the container instance to configure.