Uses of Interface
org.springframework.kafka.listener.MessageListenerContainer
Packages that use MessageListenerContainer
Package
Description
Package for kafka configuration
Package for kafka listeners
-
Uses of MessageListenerContainer in org.springframework.kafka.config
Classes in org.springframework.kafka.config with type parameters of type MessageListenerContainerMethods in org.springframework.kafka.config that return MessageListenerContainerModifier and TypeMethodDescriptionprotected MessageListenerContainerKafkaListenerEndpointRegistry.createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create and start a newMessageListenerContainerusing the specified factory.KafkaListenerEndpointRegistry.getListenerContainer(String id) Return theMessageListenerContainerwith the specified id ornullif no such container exists.Methods in org.springframework.kafka.config that return types with arguments of type MessageListenerContainerModifier and TypeMethodDescriptionKafkaListenerEndpointRegistry.getAllListenerContainers()Return allMessageListenerContainerinstances including those managed by this registry and those declared as beans in the application context.KafkaListenerEndpointRegistry.getListenerContainers()Return the managedMessageListenerContainerinstance(s).Methods in org.springframework.kafka.config with parameters of type MessageListenerContainerModifier and TypeMethodDescriptionprotected abstract MessagingMessageListenerAdapter<K,V> AbstractKafkaListenerEndpoint.createMessageListener(MessageListenerContainer container, MessageConverter messageConverter) Create aMessageListenerthat is able to serve this endpoint for the specified container.protected MessagingMessageListenerAdapter<K,V> MethodKafkaListenerEndpoint.createMessageListener(MessageListenerContainer container, MessageConverter messageConverter) voidAbstractKafkaListenerEndpoint.setupListenerContainer(MessageListenerContainer listenerContainer, MessageConverter messageConverter) voidKafkaListenerEndpoint.setupListenerContainer(MessageListenerContainer listenerContainer, MessageConverter messageConverter) Setup the specified message listener container with the model defined by this endpoint. -
Uses of MessageListenerContainer in org.springframework.kafka.listener
Subinterfaces of MessageListenerContainer in org.springframework.kafka.listenerModifier and TypeInterfaceDescriptioninterfaceGeneric message listener container; adds parameters.Classes in org.springframework.kafka.listener that implement MessageListenerContainerModifier and TypeClassDescriptionclassThe base implementation for theMessageListenerContainer.classCreates 1 or moreKafkaMessageListenerContainers based onconcurrency.classSingle-threaded Message listener container using the JavaConsumersupporting auto-partition assignment or user-configured assignment.Methods in org.springframework.kafka.listener that return MessageListenerContainerModifier and TypeMethodDescriptionListenerContainerRegistry.getListenerContainer(String id) Return theMessageListenerContainerwith the specified id ornullif no such container exists.Methods in org.springframework.kafka.listener that return types with arguments of type MessageListenerContainerModifier and TypeMethodDescriptionListenerContainerRegistry.getAllListenerContainers()Return allMessageListenerContainerinstances including those managed by this registry and those declared as beans in the application context.ListenerContainerRegistry.getListenerContainers()Return the managedMessageListenerContainerinstance(s).Methods in org.springframework.kafka.listener with parameters of type MessageListenerContainerModifier and TypeMethodDescriptionvoidContainerGroup.addContainers(MessageListenerContainer... theContainers) Add one or more containers to the group.booleanContainerGroup.contains(MessageListenerContainer container) Return true if the provided container is in this group.protected voidFailedBatchProcessor.doHandle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) static booleanSeekUtils.doSeeks(List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Exception exception, boolean recoverable, RecoveryStrategy recovery, MessageListenerContainer container, LogAccessor logger) Seek records to earliest position, optionally skipping the first.default voidBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.Handle the exception.default voidBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Deprecated.Handle the exception.default voidConsumerAwareBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.default voidConsumerAwareErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.voidContainerAwareBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.default voidContainerAwareBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Deprecated.Handle the exception.voidContainerAwareErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.default voidErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.Handle the exception.default voidListenerInvokingBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.voidListenerInvokingBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Deprecated.default voidRemainingRecordsErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated.voidCommonContainerStoppingErrorHandler.handleBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) voidCommonDelegatingErrorHandler.handleBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) default voidCommonErrorHandler.handleBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Handle the exception for a batch listener.voidCommonLoggingErrorHandler.handleBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) voidCommonMixedErrorHandler.handleBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) voidDefaultErrorHandler.handleBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) voidCommonContainerStoppingErrorHandler.handleOtherException(Exception thrownException, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) voidCommonDelegatingErrorHandler.handleOtherException(Exception thrownException, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) default voidCommonErrorHandler.handleOtherException(Exception thrownException, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) Called when an exception is thrown with no records available, e.g.voidCommonLoggingErrorHandler.handleOtherException(Exception thrownException, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) voidCommonMixedErrorHandler.handleOtherException(Exception thrownException, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) voidDefaultErrorHandler.handleOtherException(Exception thrownException, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean batchListener) default voidCommonErrorHandler.handleRecord(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Handle the exception for a record listener whenCommonErrorHandler.remainingRecords()returns false.voidCommonLoggingErrorHandler.handleRecord(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) voidCommonMixedErrorHandler.handleRecord(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) voidCommonContainerStoppingErrorHandler.handleRemaining(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) voidCommonDelegatingErrorHandler.handleRemaining(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) default voidCommonErrorHandler.handleRemaining(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Handle the exception for a record listener whenCommonErrorHandler.remainingRecords()returns true.voidCommonMixedErrorHandler.handleRemaining(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) voidDefaultErrorHandler.handleRemaining(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) voidAfterRollbackProcessor.process(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, org.apache.kafka.clients.consumer.Consumer<K, V> consumer, MessageListenerContainer container, Exception exception, boolean recoverable, ContainerProperties.EOSMode eosMode) Process the remaining records.voidDefaultAfterRollbackProcessor.process(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, org.apache.kafka.clients.consumer.Consumer<K, V> consumer, MessageListenerContainer container, Exception exception, boolean recoverable, ContainerProperties.EOSMode eosMode) booleanRecoveryStrategy.recovered(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, Exception ex, MessageListenerContainer container, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Return true if the record should be skipped because it was successfully recovered.booleanContainerGroup.removeContainer(MessageListenerContainer container) Remove a container from the group.static voidErrorHandlingUtils.retryBatch(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener, BackOff backOff, CommonErrorHandler seeker, BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<?, ?>, Exception> recoverer, LogAccessor logger, KafkaException.Level logLevel) Retry a complete batch by pausing the consumer and then, in a loop, poll the consumer, wait for the next back off, then call the listener.static voidSeekUtils.seekOrRecover(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean commitRecovered, BiPredicate<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> skipPredicate, LogAccessor logger, KafkaException.Level level) Seek the remaining records, optionally recovering the first.static voidSeekUtils.seekOrRecover(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean commitRecovered, RecoveryStrategy recovery, LogAccessor logger, KafkaException.Level level) Seek the remaining records, optionally recovering the first.static voidListenerUtils.stoppableSleep(MessageListenerContainer container, long interval) Sleep for the desired timeout, as long as the container continues to run.static voidListenerUtils.unrecoverableBackOff(BackOff backOff, ThreadLocal<BackOffExecution> executions, ThreadLocal<Long> lastIntervals, MessageListenerContainer container) Sleep according to theBackOff; when theBackOffExecutionreturnsBackOffExecution.STOPsleep for the previous backOff.Constructors in org.springframework.kafka.listener with parameters of type MessageListenerContainerModifierConstructorDescriptionContainerGroup(String name, MessageListenerContainer... containers) Construct an instance with the provided name and containers.Constructor parameters in org.springframework.kafka.listener with type arguments of type MessageListenerContainerModifierConstructorDescriptionContainerGroup(String name, List<MessageListenerContainer> containers) Construct an instance with the provided name and containers.