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
ListenerContainerFactoryConfigurer - Class in org.springframework.kafka.retrytopic
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
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