public static class KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec
extends java.lang.Object
KafkaMessageListenerContainer.| Modifier and Type | Method and Description |
|---|---|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
adminTaskExecutor(java.util.concurrent.Executor adminTaskExecutor)
Specify an
Executor for management tasks for the KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
concurrency(int concurrency)
Specify a concurrency maximum number for the
KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
dispatcherTaskExecutor(java.util.concurrent.Executor dispatcherTaskExecutor)
Specify an
Executor for MessageListener tasks for the KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
errorHandler(org.springframework.integration.kafka.listener.ErrorHandler errorHandler)
Specify an
ErrorHandler for the KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
fetchTaskExecutor(java.util.concurrent.Executor fetchTaskExecutor)
Specify an
Executor for fetch tasks for the KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
maxFetch(int maxFetch)
Specify a max fetch for the
KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
offsetManager(org.springframework.integration.kafka.listener.OffsetManager offsetManager)
Specify an
OffsetManager for the KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
queueSize(int queueSize)
Specify a queue size for the
KafkaMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
stopTimeout(int stopTimeout)
Specify a
stop timeout for the KafkaMessageListenerContainer. |
public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec offsetManager(org.springframework.integration.kafka.listener.OffsetManager offsetManager)
OffsetManager for the KafkaMessageListenerContainer.offsetManager - the OffsetManager reference.OffsetManagerpublic KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec errorHandler(org.springframework.integration.kafka.listener.ErrorHandler errorHandler)
ErrorHandler for the KafkaMessageListenerContainer.errorHandler - the ErrorHandler.ErrorHandlerpublic KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec concurrency(int concurrency)
KafkaMessageListenerContainer.concurrency - the concurrency maximum number.KafkaMessageListenerContainer.setConcurrency(int)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec stopTimeout(int stopTimeout)
stop timeout for the KafkaMessageListenerContainer.stopTimeout - timeout in milliseconds.KafkaMessageListenerContainer.setStopTimeout(int)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec fetchTaskExecutor(java.util.concurrent.Executor fetchTaskExecutor)
Executor for fetch tasks for the KafkaMessageListenerContainer.fetchTaskExecutor - the Executor.KafkaMessageListenerContainer.setFetchTaskExecutor(Executor)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec adminTaskExecutor(java.util.concurrent.Executor adminTaskExecutor)
Executor for management tasks for the KafkaMessageListenerContainer.adminTaskExecutor - the Executor.KafkaMessageListenerContainer.setAdminTaskExecutor(Executor)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec queueSize(int queueSize)
KafkaMessageListenerContainer.queueSize - the queue size.KafkaMessageListenerContainer.setQueueSize(int)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec maxFetch(int maxFetch)
KafkaMessageListenerContainer.maxFetch - the max fetch.public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec dispatcherTaskExecutor(java.util.concurrent.Executor dispatcherTaskExecutor)
Executor for MessageListener tasks for the KafkaMessageListenerContainer.dispatcherTaskExecutor - the Executor.KafkaMessageListenerContainer.setDispatcherTaskExecutor(Executor)