Uses of Class
org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec
Packages that use KafkaMessageListenerContainerSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaMessageListenerContainerSpec in org.springframework.integration.kafka.dsl
Methods in org.springframework.integration.kafka.dsl that return KafkaMessageListenerContainerSpecModifier and TypeMethodDescriptionKafkaMessageListenerContainerSpec.ackCount(int count) Set the number of outstanding record count after which offsets should be committed whenContainerProperties.AckMode.COUNTorContainerProperties.AckMode.COUNT_TIMEis 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.TIMEorContainerProperties.AckMode.COUNT_TIMEis 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 definedConsumerRebalanceListenerimplementation.KafkaMessageListenerContainerSpec.errorHandler(org.springframework.kafka.listener.CommonErrorHandler errorHandler) Specify anCommonErrorHandlerfor 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.Methods in org.springframework.integration.kafka.dsl with parameters of type KafkaMessageListenerContainerSpecModifier and TypeMethodDescriptionstatic <K,V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R> Kafka.inboundGateway(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) Create an initialKafkaInboundGatewaySpecwith the provided container and template specs.Method parameters in org.springframework.integration.kafka.dsl with type arguments of type KafkaMessageListenerContainerSpecModifier and TypeMethodDescriptionKafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumercallback, with aKafkaMessageListenerContainerSpecargument.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec.configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K, V>> configurer) Configure a listener container by invoking theConsumercallback, with aKafkaMessageListenerContainerSpecargument.