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 |
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.OffsetManager
public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec errorHandler(org.springframework.integration.kafka.listener.ErrorHandler errorHandler)
ErrorHandler
for the KafkaMessageListenerContainer
.errorHandler
- the ErrorHandler
.ErrorHandler
public 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.