Index

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

L

LATEST_ONLY - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption

Commit the current offset during partition assignment when auto.offset.reset is 'latest'; transactional if so configured.

LATEST_ONLY_NO_TX - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption

Commit the current offset during partition assignment when auto.offset.reset is 'latest'; use consumer commit even when transactions are being used.

level() - Element in annotation interface org.springframework.kafka.test.condition.LogLevels

The Log4j level name to switch the categories to during the test.

LevelsContainer(Map<Class<?>, Level>, Map<String, Level>) - Constructor for class org.springframework.kafka.test.utils.JUnitUtils.LevelsContainer

lifecycleMonitor - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

LISTENER_ENABLED_PROPERTY_NAME - Static variable in class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener

Property name used to enable the GlobalEmbeddedKafkaTestExecutionListener.

LISTENER_ID - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

Listener id (or listener container bean name).

LISTENER_INFO - Static variable in class org.springframework.kafka.support.KafkaHeaders

Arbitrary static information about the listener receiving this record.

LISTENER_OBSERVATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation

Observation for Apache Kafka listeners.

listenerContainerFactory() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

The bean name of the ConcurrentKafkaListenerContainerFactory that will be used to create the consumers for the retry and dlt topics.

listenerContainerFactoryConfigurer(KafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory, Clock) - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory

Create a ListenerContainerFactoryConfigurer that will be used to configure the KafkaListenerContainerFactory resolved by the ListenerContainerFactoryResolver.

ListenerContainerFactoryConfigurer - Class in org.springframework.kafka.retrytopic

Decorates the provided ConcurrentKafkaListenerContainerFactory to add a DefaultErrorHandler and the DeadLetterPublishingRecoverer created by the DeadLetterPublishingRecovererFactory.

ListenerContainerFactoryConfigurer(KafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory, Clock) - Constructor for class org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer

listenerContainerFactoryResolver(BeanFactory) - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory

Create the ListenerContainerFactoryResolver that will be used to resolve the appropriate KafkaListenerContainerFactory for a given topic.

ListenerContainerFactoryResolver - Class in org.springframework.kafka.retrytopic

Resolves a ConcurrentKafkaListenerContainerFactory to be used by the RetryTopicConfiguration.

ListenerContainerFactoryResolver(BeanFactory) - Constructor for class org.springframework.kafka.retrytopic.ListenerContainerFactoryResolver

ListenerContainerIdleEvent - Class in org.springframework.kafka.event

An event that is emitted when a container is idle if the container is configured to do so.

ListenerContainerIdleEvent(Object, Object, long, String, Collection<TopicPartition>, Consumer<?, ?>, boolean) - Constructor for class org.springframework.kafka.event.ListenerContainerIdleEvent

Construct an instance with the provided arguments.

ListenerContainerNoLongerIdleEvent - Class in org.springframework.kafka.event

An event that is emitted when a container is no longer idle if configured to publish idle events.

ListenerContainerNoLongerIdleEvent(Object, Object, long, String, Collection<TopicPartition>, Consumer<?, ?>) - Constructor for class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent

Construct an instance with the provided arguments.

ListenerContainerPartitionIdleEvent - Class in org.springframework.kafka.event

An event that is emitted when a container partition is idle if the container is configured to do so.

ListenerContainerPartitionIdleEvent(Object, Object, long, String, TopicPartition, Consumer<?, ?>, boolean) - Constructor for class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent

Construct an instance with the provided arguments.

ListenerContainerPartitionNoLongerIdleEvent - Class in org.springframework.kafka.event

An event that is emitted when a partition is no longer idle if configured to publish idle events.

ListenerContainerPartitionNoLongerIdleEvent(Object, Object, long, String, TopicPartition, Consumer<?, ?>) - Constructor for class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent

Construct an instance with the provided arguments.

ListenerContainerPauseService - Class in org.springframework.kafka.listener

Service for pausing and resuming of MessageListenerContainer.

ListenerContainerPauseService(ListenerContainerRegistry, TaskScheduler) - Constructor for class org.springframework.kafka.listener.ListenerContainerPauseService

Create an instance with the provided registry and scheduler.

ListenerContainerRegistry - Interface in org.springframework.kafka.listener

A registry for listener containers.

ListenerExecutionFailedException - Exception in org.springframework.kafka.listener

The listener specific KafkaException extension.

ListenerExecutionFailedException(String) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException

Construct an instance with the provided properties.

ListenerExecutionFailedException(String, String, Throwable) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException

Construct an instance with the provided properties.

ListenerExecutionFailedException(String, Throwable) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException

Construct an instance with the provided properties.

listenerFactory(String) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the container factory to use via its bean name.

listenerFactory(ConcurrentKafkaListenerContainerFactory<?, ?>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the container factory to use.

listenerId - Variable in class org.springframework.kafka.retrytopic.DestinationTopicProcessor.Context

ListenerInvokingBatchErrorHandler - Interface in org.springframework.kafka.listener

Deprecated, for removal: This API element is subject to removal in a future version.

in favor of CommonErrorHandler.

ListenerMetadata - Interface in org.springframework.kafka.listener

Metadata associated to a KafkaListener.

ListenerType - Enum Class in org.springframework.kafka.listener

Defines the listener type.

ListenerUtils - Class in org.springframework.kafka.listener

Listener utilities.

listTopics() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

log(Supplier<CharSequence>) - Method in class org.springframework.kafka.support.LogIfLevelEnabled

log(Supplier<CharSequence>, Throwable) - Method in class org.springframework.kafka.support.LogIfLevelEnabled

Log4j2LevelAdjuster - Class in org.springframework.kafka.test.rule

A JUnit method @Rule that changes the logger level for a set of classes while a test method is running.

Log4j2LevelAdjuster(Level, Class<?>...) - Constructor for class org.springframework.kafka.test.rule.Log4j2LevelAdjuster

logger - Variable in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

logger - Variable in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

logger - Variable in class org.springframework.kafka.core.KafkaTemplate

logger - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

logger - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter

logger - Variable in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

logger - Variable in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer

logger - Variable in class org.springframework.kafka.listener.FailedRecordProcessor

logger - Variable in class org.springframework.kafka.support.AbstractKafkaHeaderMapper

logger - Variable in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter

logger - Variable in class org.springframework.kafka.support.converter.MessagingMessageConverter

logger - Variable in class org.springframework.kafka.support.LoggingProducerListener

LOGGER - Static variable in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener

LogAccessor for use in default methods.

LoggingCommitCallback - Class in org.springframework.kafka.listener

Logs commit results at DEBUG level for success and ERROR for failures.

LoggingCommitCallback() - Constructor for class org.springframework.kafka.listener.LoggingCommitCallback

LoggingProducerListener<K,V> - Class in org.springframework.kafka.support

The ProducerListener that logs exceptions thrown when sending messages.

LoggingProducerListener() - Constructor for class org.springframework.kafka.support.LoggingProducerListener

LogIfLevelEnabled - Class in org.springframework.kafka.support

Wrapper for a commons-logging Log supporting configurable logging levels.

LogIfLevelEnabled(LogAccessor, LogIfLevelEnabled.Level) - Constructor for class org.springframework.kafka.support.LogIfLevelEnabled

LogIfLevelEnabled.Level - Enum Class in org.springframework.kafka.support

Logging levels.

logLateArrival(ConsumerRecord<K, R>, Object) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate

LogLevels - Annotation Interface in org.springframework.kafka.test.condition

Test classes annotated with this will change logging levels between tests.

LogLevelsCondition - Class in org.springframework.kafka.test.condition

JUnit condition that adjusts and reverts log levels before/after each test.

LogLevelsCondition() - Constructor for class org.springframework.kafka.test.condition.LogLevelsCondition

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form