K - the key type.V - the value type.public static class KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V>
extends java.lang.Object
ConcurrentMessageListenerContainer.| Modifier and Type | Method and Description |
|---|---|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
ackCount(int count)
Set the number of outstanding record count after which offsets should be
committed when
AbstractMessageListenerContainer.AckMode#COUNT
or AbstractMessageListenerContainer.AckMode#COUNT_TIME is being used. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
ackMode(org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode ackMode)
Set the ack mode to use when auto ack (in the configuration properties) is false.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
ackOnError(boolean ackOnError)
Set whether the container should ack messages that throw exceptions or not.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
ackTime(long millis)
Set the time (ms) after which outstanding offsets should be committed when
AbstractMessageListenerContainer.AckMode#TIME or
AbstractMessageListenerContainer.AckMode#COUNT_TIME is being used. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
commitCallback(org.apache.kafka.clients.consumer.OffsetCommitCallback commitCallback)
Set the commit callback; by default a simple logging callback is used to log
success at DEBUG level and failures at ERROR level.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
concurrency(int concurrency)
Specify a concurrency maximum number for the
AbstractMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
consumerRebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)
Set the user defined
ConsumerRebalanceListener implementation. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
consumerTaskExecutor(org.springframework.core.task.AsyncListenableTaskExecutor consumerTaskExecutor)
Set the executor for threads that poll the consumer.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
errorHandler(org.springframework.kafka.listener.ErrorHandler errorHandler)
Specify an
ErrorHandler for the AbstractMessageListenerContainer. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
idleEventInterval(java.lang.Long idleEventInterval)
Set the idle event interval; when set, an event is emitted if a poll returns
no records and this interval has elapsed since a record was returned.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
listenerTaskExecutor(org.springframework.core.task.AsyncListenableTaskExecutor listenerTaskExecutor)
Set the executor for threads that invoke the listener.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
pauseAfter(long pauseAfter)
When using Kafka group management and
pauseEnabled(boolean) is
true, set the delay after which the consumer should be paused. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
pauseEnabled(boolean pauseEnabled)
Set to true to avoid rebalancing when this consumer is slow or throws a
qualifying exception - pause the consumer.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
pollTimeout(long pollTimeout)
Set the max time to block in the consumer waiting for records.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
queueDepth(int queueDepth)
Set the queue depth for handoffs from the consumer thread to the listener
thread.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
shutdownTimeout(long shutdownTimeout)
Set the timeout for shutting down the container.
|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
syncCommits(boolean syncCommits)
Set whether or not to call consumer.commitSync() or commitAsync() when the
container is responsible for commits.
|
public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> concurrency(int concurrency)
AbstractMessageListenerContainer.concurrency - the concurrency maximum number.ConcurrentMessageListenerContainer.setConcurrency(int)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> errorHandler(org.springframework.kafka.listener.ErrorHandler errorHandler)
ErrorHandler for the AbstractMessageListenerContainer.errorHandler - the ErrorHandler.ErrorHandlerpublic KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> ackMode(org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode ackMode)
#setPollTimeout(long) pollTimeout.AcknowledgingMessageListener.
ackMode - the AbstractMessageListenerContainer.AckMode; default BATCH.AbstractMessageListenerContainer.AckModepublic KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> pollTimeout(long pollTimeout)
pollTimeout - the timeout in ms; default 1000.ContainerProperties.setPollTimeout(long)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> ackCount(int count)
AbstractMessageListenerContainer.AckMode#COUNT
or AbstractMessageListenerContainer.AckMode#COUNT_TIME is being used.count - the countContainerProperties.setAckCount(int)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> ackTime(long millis)
AbstractMessageListenerContainer.AckMode#TIME or
AbstractMessageListenerContainer.AckMode#COUNT_TIME is being used.
Should be larger than zero.millis - the timeContainerProperties.setAckTime(long)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> consumerTaskExecutor(org.springframework.core.task.AsyncListenableTaskExecutor consumerTaskExecutor)
consumerTaskExecutor - the executorContainerProperties.setConsumerTaskExecutor(AsyncListenableTaskExecutor)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> listenerTaskExecutor(org.springframework.core.task.AsyncListenableTaskExecutor listenerTaskExecutor)
listenerTaskExecutor - the executorContainerProperties.setListenerTaskExecutor(AsyncListenableTaskExecutor)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> pauseAfter(long pauseAfter)
pauseEnabled(boolean) is
true, set the delay after which the consumer should be paused. Default 10000.pauseAfter - the delay.ContainerProperties.setPauseAfter(long)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> pauseEnabled(boolean pauseEnabled)
pauseEnabled - true to pause.pauseAfter(long),
ContainerProperties.setPauseEnabled(boolean)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> queueDepth(int queueDepth)
queueDepth - the queue depth.ContainerProperties.setQueueDepth(int)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> shutdownTimeout(long shutdownTimeout)
#stop(Runnable) will block for, before
returning.shutdownTimeout - the shutdown timeout.ContainerProperties.setShutdownTimeout(long)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> consumerRebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)
ConsumerRebalanceListener implementation.consumerRebalanceListener - the ConsumerRebalanceListener instanceContainerProperties.setConsumerRebalanceListener(ConsumerRebalanceListener)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> commitCallback(org.apache.kafka.clients.consumer.OffsetCommitCallback commitCallback)
commitCallback - the callback.ContainerProperties.setCommitCallback(OffsetCommitCallback)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> syncCommits(boolean syncCommits)
syncCommits - true to use commitSync().ContainerProperties.setSyncCommits(boolean)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> idleEventInterval(java.lang.Long idleEventInterval)
idleEventInterval - the interval.ContainerProperties.setIdleEventInterval(Long)public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> ackOnError(boolean ackOnError)
ackOnError - whether the container should acknowledge messages that throw
exceptions.ContainerProperties.setAckOnError(boolean)