Uses of Class
org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaMessageListenerContainerSpec in org.springframework.integration.kafka.dsl
Modifier and TypeMethodDescriptionKafkaMessageListenerContainerSpec.ackCount
(int count) Set the number of outstanding record count after which offsets should be committed whenContainerProperties.AckMode.COUNT
orContainerProperties.AckMode.COUNT_TIME
is being used.KafkaMessageListenerContainerSpec.ackMode
(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode) Set the ack mode to use when auto ack (in the configuration properties) is false.KafkaMessageListenerContainerSpec.ackTime
(long millis) Set the time (ms) after which outstanding offsets should be committed whenContainerProperties.AckMode.TIME
orContainerProperties.AckMode.COUNT_TIME
is being used.KafkaMessageListenerContainerSpec.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.KafkaMessageListenerContainerSpec.concurrency
(int concurrency) Specify a concurrency maximum number for theAbstractMessageListenerContainer
.KafkaMessageListenerContainerSpec.consumerRebalanceListener
(org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener) Set the user definedConsumerRebalanceListener
implementation.KafkaMessageListenerContainerSpec.errorHandler
(org.springframework.kafka.listener.CommonErrorHandler errorHandler) Specify anCommonErrorHandler
for theAbstractMessageListenerContainer
.Set the group id for this container.KafkaMessageListenerContainerSpec.idleEventInterval
(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.KafkaMessageListenerContainerSpec.listenerTaskExecutor
(AsyncTaskExecutor consumerTaskExecutor) Set the executor for threads that poll the consumer.KafkaMessageListenerContainerSpec.pollTimeout
(long pollTimeout) Set the max time to block in the consumer waiting for records.KafkaMessageListenerContainerSpec.shutdownTimeout
(long shutdownTimeout) Set the timeout for shutting down the container.KafkaMessageListenerContainerSpec.syncCommits
(boolean syncCommits) Set whether to call consumer.commitSync() or commitAsync() when the container is responsible for commits.Modifier and TypeMethodDescriptionstatic <K,
V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R> Kafka.inboundGateway
(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) Create an initialKafkaInboundGatewaySpec
with the provided container and template specs.Modifier and TypeMethodDescriptionKafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureListenerContainer
(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumer
callback, with aKafkaMessageListenerContainerSpec
argument.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec.configureListenerContainer
(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumer
callback, with aKafkaMessageListenerContainerSpec
argument.