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.KafkaListenerEndpointRegistry.getUnregisteredListenerContainer(String id) KafkaListenerEndpointRegistry.unregisterListenerContainer(String id) Unregister the listener container with the provided id.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.Method parameters in org.springframework.kafka.config with type arguments of type MessageListenerContainerModifier and TypeMethodDescriptionvoidAbstractKafkaListenerContainerFactory.setThreadNameSupplier(Function<MessageListenerContainer, String> threadNameSupplier) Set a function used to change the consumer thread name. -
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 TypeMethodDescriptionConcurrentMessageListenerContainer.getContainerFor(String topic, int partition) default MessageListenerContainerMessageListenerContainer.getContainerFor(String topic, int partition) If this container has child containers, return the child container that is assigned the topic/partition.ListenerContainerRegistry.getListenerContainer(String id) Return theMessageListenerContainerwith the specified id ornullif no such container exists.ListenerContainerRegistry.getUnregisteredListenerContainer(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).AbstractMessageListenerContainer.getThreadNameSupplier()Return the function used to change the consumer thread name.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.static org.apache.kafka.clients.consumer.OffsetAndMetadataListenerUtils.createOffsetAndMetadata(MessageListenerContainer container, long offset) Create a newOffsetAndMetadatausing the given container and offset.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, for removal: This API element is subject to removal in a future version.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, for removal: This API element is subject to removal in a future version.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, for removal: This API element is subject to removal in a future version.default voidConsumerAwareErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.voidContainerAwareBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.default voidContainerAwareBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Deprecated, for removal: This API element is subject to removal in a future version.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, for removal: This API element is subject to removal in a future version.default voidErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.Handle the exception.protected <K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K, V> FailedBatchProcessor.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) default voidListenerInvokingBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.voidListenerInvokingBatchErrorHandler.handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Deprecated, for removal: This API element is subject to removal in a future version.default voidRemainingRecordsErrorHandler.handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.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) default <K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K, V> CommonErrorHandler.handleBatchAndReturnRemaining(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.<K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K, V> DefaultErrorHandler.handleBatchAndReturnRemaining(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) default booleanCommonErrorHandler.handleOne(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.booleanCommonMixedErrorHandler.handleOne(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) booleanDefaultErrorHandler.handleOne(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) 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) Deprecated, for removal: This API element is subject to removal in a future version.voidCommonLoggingErrorHandler.handleRecord(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.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) default voidBackOffHandler.onNextBackOff(MessageListenerContainer container, Exception exception, long nextBackOff) Perform the next back off.default voidBackOffHandler.onNextBackOff(MessageListenerContainer container, org.apache.kafka.common.TopicPartition partition, long nextBackOff) Perform the next back off for a partition.voidContainerPausingBackOffHandler.onNextBackOff(MessageListenerContainer container, Exception exception, long nextBackOff) voidContainerPausingBackOffHandler.onNextBackOff(MessageListenerContainer container, org.apache.kafka.common.TopicPartition partition, long nextBackOff) voidDefaultBackOffHandler.onNextBackOff(MessageListenerContainer container, Exception exception, long nextBackOff) voidListenerContainerPauseService.pause(MessageListenerContainer messageListenerContainer, Duration pauseDuration) Pause the listener by given container instance.voidListenerContainerPauseService.pausePartition(MessageListenerContainer messageListenerContainer, org.apache.kafka.common.TopicPartition partition, Duration pauseDuration) Pause consumption from a given partition for the duration.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.voidListenerContainerPauseService.resume(MessageListenerContainer messageListenerContainer) Resume the listener container.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, List<RetryListener> retryListeners, org.springframework.classify.BinaryExceptionClassifier classifier) 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.Method parameters in org.springframework.kafka.listener with type arguments of type MessageListenerContainerModifier and TypeMethodDescriptionvoidAbstractMessageListenerContainer.setThreadNameSupplier(Function<MessageListenerContainer, String> threadNameSupplier) Set a function used to change the consumer thread name.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.
CommonErrorHandler.handleOne(Exception, ConsumerRecord, Consumer, MessageListenerContainer).